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 d6a6b37f19ea9dbae4af6e3b8adea561dffcb48f Author: Gabriel <[email protected]> AuthorDate: Wed Apr 17 15:09:04 2024 +0800 [shuffle](minor) Log error status if exchange is shutdown early (#33748) --- be/src/vec/sink/vdata_stream_sender.cpp | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/be/src/vec/sink/vdata_stream_sender.cpp b/be/src/vec/sink/vdata_stream_sender.cpp index c220a76317a..ce6a5317fd4 100644 --- a/be/src/vec/sink/vdata_stream_sender.cpp +++ b/be/src/vec/sink/vdata_stream_sender.cpp @@ -85,8 +85,9 @@ Status Channel<Parent>::init(RuntimeState* state) { } if (_is_local) { - RETURN_IF_ERROR(_parent->state()->exec_env()->vstream_mgr()->find_recvr( - _fragment_instance_id, _dest_node_id, &_local_recvr)); + WARN_IF_ERROR(_parent->state()->exec_env()->vstream_mgr()->find_recvr( + _fragment_instance_id, _dest_node_id, &_local_recvr), + ""); } else { if (_brpc_dest_addr.hostname == BackendOptions::get_localhost()) { _brpc_stub = state->exec_env()->brpc_internal_client_cache()->get_client( @@ -125,8 +126,9 @@ Status Channel<Parent>::init_stub(RuntimeState* state) { _is_local &= state->query_options().enable_local_exchange; } if (_is_local) { - RETURN_IF_ERROR(_parent->state()->exec_env()->vstream_mgr()->find_recvr( - _fragment_instance_id, _dest_node_id, &_local_recvr)); + WARN_IF_ERROR(_parent->state()->exec_env()->vstream_mgr()->find_recvr( + _fragment_instance_id, _dest_node_id, &_local_recvr), + ""); return Status::OK(); } if (_brpc_dest_addr.hostname == BackendOptions::get_localhost()) { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
