This is an automated email from the ASF dual-hosted git repository.
panxiaolei 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 76958ed9ce0 [chore](log) Reduce some BE execution log (#42383)
76958ed9ce0 is described below
commit 76958ed9ce050e714dd0a406e69b31e8cb4f47a0
Author: zclllhhjj <[email protected]>
AuthorDate: Mon Oct 28 10:19:09 2024 +0800
[chore](log) Reduce some BE execution log (#42383)
1. timeout does not print stack
2. when the runtime filter's relative query is finished before, it does
not print the log.
---
be/src/common/status.h | 2 +-
be/src/runtime/fragment_mgr.cpp | 3 +--
2 files changed, 2 insertions(+), 3 deletions(-)
diff --git a/be/src/common/status.h b/be/src/common/status.h
index e95b9343167..e6c4b687116 100644
--- a/be/src/common/status.h
+++ b/be/src/common/status.h
@@ -478,7 +478,7 @@ public:
ERROR_CTOR_NOSTACK(Cancelled, CANCELLED)
ERROR_CTOR(MemoryLimitExceeded, MEM_LIMIT_EXCEEDED)
ERROR_CTOR(RpcError, THRIFT_RPC_ERROR)
- ERROR_CTOR(TimedOut, TIMEOUT)
+ ERROR_CTOR_NOSTACK(TimedOut, TIMEOUT)
ERROR_CTOR_NOSTACK(TooManyTasks, TOO_MANY_TASKS)
ERROR_CTOR(Uninitialized, UNINITIALIZED)
ERROR_CTOR(Aborted, ABORTED)
diff --git a/be/src/runtime/fragment_mgr.cpp b/be/src/runtime/fragment_mgr.cpp
index 26fb098c76d..96d49be4c12 100644
--- a/be/src/runtime/fragment_mgr.cpp
+++ b/be/src/runtime/fragment_mgr.cpp
@@ -602,6 +602,7 @@ void FragmentMgr::remove_pipeline_context(
.count();
g_fragment_executing_count << -1;
g_fragment_last_active_time.set_value(now);
+ // this log will show when a query is really finished in BEs
LOG_INFO("Removing query {} fragment {}", print_id(query_id),
f_context->get_fragment_id());
_pipeline_map.erase({query_id, f_context->get_fragment_id()});
}
@@ -1138,8 +1139,6 @@ Status FragmentMgr::apply_filterv2(const
PPublishFilterRequestV2* request,
auto iter = _pipeline_map.find(
{UniqueId(request->query_id()).to_thrift(),
fragment_id});
if (iter == _pipeline_map.end()) {
- LOG(WARNING) << "No pipeline fragment is found: Query-ID =
"
- << request->query_id() << " fragment_id = "
<< fragment_id;
continue;
}
pip_context = iter->second;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
