This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 2b271634429de05f46440b932d6affcbd8c2e9ee Author: yiguolei <[email protected]> AuthorDate: Wed Apr 24 19:39:59 2024 +0800 [bugfix](core) close method should check if the pointer is nullptr (#34067) Co-authored-by: yiguolei <[email protected]> --- be/src/pipeline/exec/exchange_sink_operator.cpp | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/be/src/pipeline/exec/exchange_sink_operator.cpp b/be/src/pipeline/exec/exchange_sink_operator.cpp index 580e8e525d6..79a6ee0e748 100644 --- a/be/src/pipeline/exec/exchange_sink_operator.cpp +++ b/be/src/pipeline/exec/exchange_sink_operator.cpp @@ -685,7 +685,8 @@ Status ExchangeSinkLocalState::close(RuntimeState* state, Status exec_status) { if (_closed) { return Status::OK(); } - if (_part_type == TPartitionType::TABLET_SINK_SHUFFLE_PARTITIONED) { + if (_part_type == TPartitionType::TABLET_SINK_SHUFFLE_PARTITIONED && + _block_convertor != nullptr && _tablet_finder != nullptr) { _state->update_num_rows_load_filtered(_block_convertor->num_filtered_rows() + _tablet_finder->num_filtered_rows()); _state->update_num_rows_load_unselected( --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
