This is an automated email from the ASF dual-hosted git repository.
gabriellee pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from e69c4e1900a [fix](ui): fix data preview error (#34521)
add 85026759d6e [conf](pipeline) Disable non-pipeline engine (#34812)
No new revisions were added by this update.
Summary of changes:
be/src/common/config.cpp | 1 +
be/src/common/config.h | 1 +
be/src/http/action/http_stream.cpp | 12 +-
.../pipeline/exec/group_commit_scan_operator.cpp | 58 ++++++++
...set_operator.h => group_commit_scan_operator.h} | 33 +++--
.../pipeline/exec/memory_scratch_sink_operator.cpp | 116 ++++++++++++++++
.../pipeline/exec/memory_scratch_sink_operator.h | 68 +++++++++
be/src/pipeline/exec/operator.cpp | 4 +
be/src/pipeline/exec/scan_operator.cpp | 3 +
be/src/pipeline/pipeline_fragment_context.cpp | 24 +++-
be/src/runtime/fragment_mgr.cpp | 10 +-
be/src/runtime/group_commit_mgr.cpp | 152 +++++++++++----------
be/src/runtime/record_batch_queue.cpp | 9 ++
be/src/runtime/record_batch_queue.h | 10 +-
.../cloud/planner/CloudStreamLoadPlanner.java | 3 +-
.../org/apache/doris/load/StreamLoadHandler.java | 3 +-
.../apache/doris/load/loadv2/LoadLoadingTask.java | 2 +-
.../doris/load/routineload/KafkaTaskInfo.java | 7 +-
.../doris/load/routineload/RoutineLoadJob.java | 5 +-
.../apache/doris/planner/GroupCommitPlanner.java | 21 +--
.../apache/doris/planner/StreamLoadPlanner.java | 20 ++-
.../main/java/org/apache/doris/qe/Coordinator.java | 27 ++--
.../java/org/apache/doris/qe/HttpStreamParams.java | 4 +-
.../apache/doris/qe/InsertStreamTxnExecutor.java | 23 +---
.../apache/doris/service/FrontendServiceImpl.java | 16 ++-
.../doris/statistics/util/StatisticsUtil.java | 2 +-
.../doris/load/sync/canal/CanalSyncDataTest.java | 12 +-
gensrc/thrift/PaloInternalService.thrift | 2 +
.../test_select_stddev_variance_window.out | 34 -----
.../correctness_p0/test_grouping_sets_empty.groovy | 5 -
.../suites/correctness_p0/test_probe_clean.groovy | 5 +-
.../suites/nereids_tpch_p0/tpch/topn-filter.groovy | 2 -
.../bitmap_functions/test_bitmap_function.groovy | 1 -
.../test_select_stddev_variance_window.groovy | 12 --
34 files changed, 466 insertions(+), 241 deletions(-)
create mode 100644 be/src/pipeline/exec/group_commit_scan_operator.cpp
copy be/src/pipeline/exec/{empty_set_operator.h =>
group_commit_scan_operator.h} (51%)
create mode 100644 be/src/pipeline/exec/memory_scratch_sink_operator.cpp
create mode 100644 be/src/pipeline/exec/memory_scratch_sink_operator.h
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
