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 eccec4a7d39 [fix](routine-load) fix get kafka offset timeout may too
long (#33502)
add 25a85aae02d [refactor](pipelineX) Reduce prepare overhead (PART I)
(#33550)
No new revisions were added by this update.
Summary of changes:
be/src/pipeline/exec/aggregation_sink_operator.cpp | 46 ++++++-------
.../pipeline/exec/aggregation_source_operator.cpp | 2 +-
be/src/pipeline/exec/analytic_sink_operator.cpp | 14 ++--
be/src/pipeline/exec/analytic_sink_operator.h | 1 +
be/src/pipeline/exec/analytic_source_operator.cpp | 14 ++--
be/src/pipeline/exec/analytic_source_operator.h | 1 +
.../distinct_streaming_aggregation_operator.cpp | 23 ++++---
.../exec/distinct_streaming_aggregation_operator.h | 1 +
be/src/pipeline/exec/exchange_sink_operator.cpp | 47 +++++++++-----
be/src/pipeline/exec/exchange_sink_operator.h | 12 ++--
be/src/pipeline/exec/exchange_source_operator.cpp | 14 ++--
be/src/pipeline/exec/repeat_operator.cpp | 4 +-
be/src/pipeline/exec/repeat_operator.h | 2 +-
be/src/pipeline/exec/result_sink_operator.cpp | 9 +--
be/src/pipeline/exec/result_sink_operator.h | 4 +-
be/src/pipeline/exec/scan_operator.cpp | 23 +++----
be/src/pipeline/exec/schema_scan_operator.cpp | 5 +-
be/src/pipeline/exec/set_probe_sink_operator.cpp | 18 ++++--
be/src/pipeline/exec/set_probe_sink_operator.h | 1 +
be/src/pipeline/exec/set_sink_operator.cpp | 28 +++++---
be/src/pipeline/exec/set_sink_operator.h | 1 +
be/src/pipeline/exec/set_source_operator.cpp | 4 +-
be/src/pipeline/exec/sort_sink_operator.cpp | 14 ++--
be/src/pipeline/exec/sort_sink_operator.h | 5 +-
be/src/pipeline/exec/spill_sort_sink_operator.cpp | 9 ++-
be/src/pipeline/exec/spill_sort_sink_operator.h | 1 -
.../pipeline/exec/spill_sort_source_operator.cpp | 4 ++
.../exec/streaming_aggregation_operator.cpp | 28 +++++---
.../pipeline/exec/streaming_aggregation_operator.h | 1 +
be/src/pipeline/exec/table_function_operator.cpp | 6 +-
be/src/pipeline/exec/table_function_operator.h | 2 +-
be/src/pipeline/exec/union_sink_operator.cpp | 12 +++-
be/src/pipeline/exec/union_sink_operator.h | 1 +
be/src/pipeline/exec/union_source_operator.cpp | 17 +++--
be/src/pipeline/exec/union_source_operator.h | 1 +
be/src/pipeline/pipeline_x/operator.cpp | 2 +
be/src/pipeline/pipeline_x/operator.h | 2 +
be/src/pipeline/pipeline_x/pipeline_x_task.cpp | 15 ++---
be/src/vec/runtime/vdata_stream_mgr.cpp | 17 +++--
be/src/vec/runtime/vdata_stream_mgr.h | 4 +-
be/src/vec/sink/vdata_stream_sender.cpp | 75 ++++++++++++++++++++--
be/src/vec/sink/vdata_stream_sender.h | 7 +-
.../main/java/org/apache/doris/qe/Coordinator.java | 4 +-
.../java/org/apache/doris/qe/SessionVariable.java | 11 ----
44 files changed, 332 insertions(+), 180 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
