diff --git a/be/src/runtime/fragment_mgr.cpp b/be/src/runtime/fragment_mgr.cpp
index 5cd403d4228f37..4178e2190a6c87 100644
--- a/be/src/runtime/fragment_mgr.cpp
+++ b/be/src/runtime/fragment_mgr.cpp
@@ -452,6 +452,9 @@ FragmentMgr::~FragmentMgr() {
 static void empty_function(PlanFragmentExecutor* exec) {}
 
 void FragmentMgr::_exec_actual(std::shared_ptr<FragmentExecState> exec_state, FinishCallback cb) {
+    TAG(LOG(INFO)).log("PlanFragmentExecutor::_exec_actual")
+            .query_id(exec_state->query_id()).instance_id(exec_state->fragment_instance_id())
+            .tag("pthread_id", std::to_string((uintptr_t) pthread_self()));
     exec_state->execute();
 
     std::shared_ptr<QueryFragmentsCtx> fragments_ctx = exec_state->get_fragments_ctx();
diff --git a/be/src/runtime/plan_fragment_executor.cpp b/be/src/runtime/plan_fragment_executor.cpp
index 670248ee14bf33..ecb3f4395727e3 100644
--- a/be/src/runtime/plan_fragment_executor.cpp
+++ b/be/src/runtime/plan_fragment_executor.cpp
@@ -39,6 +39,7 @@
 #include "util/mem_info.h"
 #include "util/parse_util.h"
 #include "util/pretty_printer.h"
+#include "util/uid_util.h"
 #include "util/logging.h"
 
 namespace doris {
@@ -71,7 +72,8 @@ Status PlanFragmentExecutor::prepare(const TExecPlanFragmentParams& request,
 
     TAG(LOG(INFO)).log("PlanFragmentExecutor::prepare")
                   .query_id(_query_id).instance_id(params.fragment_instance_id)
-                  .tag("backend_num", std::to_string(request.backend_num));
+                  .tag("backend_num", std::to_string(request.backend_num))
+                  .tag("pthread_id", std::to_string((uintptr_t) pthread_self()));
     // VLOG_CRITICAL << "request:\n" << apache::thrift::ThriftDebugString(request);
 
     const TQueryGlobals& query_globals =