[opt](nereids) hbo fix pb

xzj7019 · Dec 17, 2024 · 8ea0224 · 8ea0224
1 parent 24f5925
commit 8ea0224
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/be/src/runtime/runtime_query_statistics_mgr.cpp b/be/src/runtime/runtime_query_statistics_mgr.cpp
@@ -413,7 +413,11 @@ void RuntimeQueryStatisticsMgr::report_runtime_query_statistics() {
         // 2.2 send report
         TReportWorkloadRuntimeStatusParams report_runtime_params;
         report_runtime_params.__set_backend_id(be_id);
-        std::map<std::string, TQueryStatistics> temp_map = qs_map;
+        for (const auto& entry : qs_map) {
+            std::string query_id = entry.first;
+            TQueryStatistics temp_qs = entry.second;
+            LOG(INFO) << "zxiong10 " << query_id << " size: " << temp_qs.node_exec_stats_items.size();
+        }
 
         report_runtime_params.__set_query_statistics_map(qs_map);
 

diff --git a/...src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadRuntimeStatusMgr.java b/...src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadRuntimeStatusMgr.java
@@ -169,6 +169,7 @@ public void updateBeQueryStats(TReportWorkloadRuntimeStatusParams params) {
         for (Map.Entry<String, TQueryStatistics> entry : params.query_statistics_map.entrySet()) {
             beReportInfo.queryStatsMap.put(entry.getKey(), Pair.of(currentTime, (TQueryStatistics) entry.getValue()));
         }
+
     }
 
     void clearReportTimeoutBeStatistics() {
-Original file line number
+Diff line change
@@ Expand Up @@
             for (Map.Entry<String, TQueryStatistics> entry : params.query_statistics_map.entrySet()) {
                 beReportInfo.queryStatsMap.put(entry.getKey(), Pair.of(currentTime, (TQueryStatistics) entry.getValue()));
             }
         }
         void clearReportTimeoutBeStatistics() {
@@ Expand Down @@