From d7205a30f3df8efae93b4e55fd1f0255bbbe33e1 Mon Sep 17 00:00:00 2001 From: Gabriel Date: Wed, 17 Apr 2024 11:47:08 +0800 Subject: [PATCH] [shuffle](minor) Log error status if exchange is shutdown early --- 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 c220a76317aba6..ce6a5317fd4be6 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::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::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()) {