This is an automated email from the ASF dual-hosted git repository.
panxiaolei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 5312a85ffea [fix](regression) cloud disable case
test_be_inject_publish_txn_fail (#47852)
add 0d8769661f5 [test](beut) add exchange sink operator be ut case (#47705)
No new revisions were added by this update.
Summary of changes:
be/src/pipeline/exec/exchange_sink_operator.cpp | 52 +++---
be/src/pipeline/exec/exchange_sink_operator.h | 8 +-
be/src/runtime/runtime_state.h | 6 +-
be/src/vec/sink/vdata_stream_sender.cpp | 51 +++---
be/src/vec/sink/vdata_stream_sender.h | 11 +-
.../operator/exchange_sink_operator_test.cpp | 192 +++++++++++++++++++++
be/test/pipeline/operator/operator_helper.h | 2 +-
be/test/testutil/column_helper.h | 12 ++
be/test/testutil/mock/mock_data_stream_sender.h | 79 +++++++++
be/test/testutil/mock/mock_runtime_state.h | 16 +-
10 files changed, 378 insertions(+), 51 deletions(-)
create mode 100644 be/test/pipeline/operator/exchange_sink_operator_test.cpp
create mode 100644 be/test/testutil/mock/mock_data_stream_sender.h
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
