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 f05cf95daa2 [fix](virtual slot) Fix grouping scalar function (#56127)
add 7146661fa62 [fix](union) Terminate union sink if sources finished
(#56153)
No new revisions were added by this update.
Summary of changes:
be/src/pipeline/exec/cache_sink_operator.cpp | 4 ++--
be/src/pipeline/exec/data_queue.cpp | 22 ++++++++++++++++++++--
be/src/pipeline/exec/data_queue.h | 4 +++-
be/src/pipeline/exec/union_sink_operator.cpp | 12 ++++++------
be/src/pipeline/exec/union_source_operator.cpp | 12 ++++++++++++
be/src/pipeline/exec/union_source_operator.h | 1 +
be/test/pipeline/exec/data_queue_test.cpp | 2 +-
7 files changed, 45 insertions(+), 12 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
