diff --git a/be/src/runtime/query_statistics.cpp b/be/src/runtime/query_statistics.cpp
index 0a20f6d6e0a56d..754baa7a7b7f5b 100644
--- a/be/src/runtime/query_statistics.cpp
+++ b/be/src/runtime/query_statistics.cpp
@@ -131,8 +131,8 @@ void QueryStatisticsRecvr::insert(const PQueryStatistics& statistics, int sender
 
 void QueryStatisticsRecvr::insert(QueryStatisticsPtr statistics, int sender_id) {
     if (!statistics->collected()) return;
-    if (_query_statistics.contains(sender_id)) return;
     std::lock_guard<SpinLock> l(_lock);
+    if (_query_statistics.contains(sender_id)) return;
     _query_statistics[sender_id] = statistics;
 }