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 02b5625220e [Enhancement](Compaction) Add cumulative compaction delay
strategy (#48759)
add 3497f67f6cf [refactor](terminate) add terminate interface (#49638)
No new revisions were added by this update.
Summary of changes:
be/src/pipeline/dependency.cpp | 3 --
be/src/pipeline/exec/hashjoin_build_sink.cpp | 28 +++++++++------
be/src/pipeline/exec/hashjoin_build_sink.h | 1 +
be/src/pipeline/exec/operator.cpp | 37 ++++++++++++++++++++
be/src/pipeline/exec/operator.h | 9 +++++
.../exec/partitioned_hash_join_sink_operator.cpp | 2 --
be/src/pipeline/exec/set_probe_sink_operator.cpp | 6 +---
be/src/pipeline/pipeline_fragment_context.cpp | 1 -
be/src/pipeline/pipeline_task.cpp | 40 +++++++++++-----------
be/src/pipeline/pipeline_task.h | 2 --
be/src/runtime/runtime_state.h | 4 ---
.../runtime_filter_producer_helper.cpp | 33 +++++++++++++-----
.../runtime_filter_producer_helper.h | 12 ++++---
.../runtime_filter_producer_helper_cross.h | 2 +-
be/src/vec/exprs/vexpr.cpp | 6 ----
.../partitioned_aggregation_test_helper.cpp | 1 -
.../operator/partitioned_hash_join_test_helper.cpp | 1 -
.../pipeline/operator/spill_sort_test_helper.cpp | 1 -
be/test/pipeline/pipeline_test.cpp | 2 --
.../runtime_filter_consumer_helper_test.cpp | 1 -
.../runtime_filter_producer_helper_cross_test.cpp | 1 -
.../runtime_filter_producer_helper_test.cpp | 17 ++++-----
22 files changed, 128 insertions(+), 82 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
