This is an automated email from the ASF dual-hosted git repository.
gabriellee pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 1bfd8b1c2ef [minor](log) Refactor some warning logs (#35973)
1bfd8b1c2ef is described below
commit 1bfd8b1c2ef44ceb786e4c5c44736f464a9b3b9f
Author: Gabriel <[email protected]>
AuthorDate: Thu Jun 6 21:37:36 2024 +0800
[minor](log) Refactor some warning logs (#35973)
---
be/src/runtime/fragment_mgr.cpp | 5 -----
be/src/vec/runtime/vdata_stream_mgr.cpp | 4 ++--
be/src/vec/sink/vdata_stream_sender.cpp | 9 ++++++---
3 files changed, 8 insertions(+), 10 deletions(-)
diff --git a/be/src/runtime/fragment_mgr.cpp b/be/src/runtime/fragment_mgr.cpp
index 8222b75cfc3..6dab87e1592 100644
--- a/be/src/runtime/fragment_mgr.cpp
+++ b/be/src/runtime/fragment_mgr.cpp
@@ -870,9 +870,6 @@ void FragmentMgr::cancel_worker() {
++it;
}
} else {
- LOG_WARNING(
- "Query context for {} is released, just erase it
from _query_ctx_map",
- print_id(it->first));
it = _query_ctx_map.erase(it);
}
}
@@ -1204,8 +1201,6 @@ void
FragmentMgr::get_runtime_query_info(std::vector<WorkloadQueryInfo>* query_i
query_info_list->push_back(workload_query_info);
iter++;
} else {
- LOG_WARNING("Query context for {} is released, just erase it
from _query_ctx_map",
- print_id(iter->first));
iter = _query_ctx_map.erase(iter);
}
}
diff --git a/be/src/vec/runtime/vdata_stream_mgr.cpp
b/be/src/vec/runtime/vdata_stream_mgr.cpp
index 46d335fbf00..4e48effb566 100644
--- a/be/src/vec/runtime/vdata_stream_mgr.cpp
+++ b/be/src/vec/runtime/vdata_stream_mgr.cpp
@@ -97,8 +97,8 @@ Status VDataStreamMgr::find_recvr(const TUniqueId&
fragment_instance_id, PlanNod
}
++range.first;
}
- return Status::InternalError("Could not find local receiver for node {}
with instance {}",
- node_id, print_id(fragment_instance_id));
+ return Status::InvalidArgument("Could not find local receiver for node {}
with instance {}",
+ node_id, print_id(fragment_instance_id));
}
Status VDataStreamMgr::transmit_block(const PTransmitDataParams* request,
diff --git a/be/src/vec/sink/vdata_stream_sender.cpp
b/be/src/vec/sink/vdata_stream_sender.cpp
index 939a59b1847..69053c6bdac 100644
--- a/be/src/vec/sink/vdata_stream_sender.cpp
+++ b/be/src/vec/sink/vdata_stream_sender.cpp
@@ -66,9 +66,12 @@ Status Channel<Parent>::init_stub(RuntimeState* state) {
_is_local &= state->query_options().enable_local_exchange;
}
if (_is_local) {
- WARN_IF_ERROR(_parent->state()->exec_env()->vstream_mgr()->find_recvr(
- _fragment_instance_id, _dest_node_id,
&_local_recvr),
- "");
+ auto st = _parent->state()->exec_env()->vstream_mgr()->find_recvr(
+ _fragment_instance_id, _dest_node_id, &_local_recvr);
+ if (!st.ok()) {
+ // Recvr not found. Maybe downstream task is finished already.
+ LOG(INFO) << "Recvr is not found : " << st.to_string();
+ }
return Status::OK();
}
if (_brpc_dest_addr.hostname == BackendOptions::get_localhost()) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
