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;