From 3ca52ac14a72c39671954d9c1eeea88ced0663c3 Mon Sep 17 00:00:00 2001 From: zhaochangle Date: Thu, 24 Oct 2024 13:12:32 +0800 Subject: [PATCH] 1 --- 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 e95b93431679a2..e6c4b6871168e7 100644 --- a/be/src/common/status.h +++ b/be/src/common/status.h @@ -478,7 +478,7 @@ class [[nodiscard]] Status { 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 26fb098c76dfc5..96d49be4c126df 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;