f

apache · Mar 30, 2024 · 4636b97 · 4636b97
1 parent daadffa
commit 4636b97
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/profile/ExecutionProfile.java b/fe/fe-core/src/main/java/org/apache/doris/common/profile/ExecutionProfile.java
@@ -245,6 +245,7 @@ public void update(long startTime, boolean isFinished) {
 
     public void updateProfile(TReportExecStatusParams params, TNetworkAddress address) {
         if (isPipelineXProfile) {
+            LOG.debug("params: {}", params);
             int pipelineIdx = 0;
             List<RuntimeProfile> taskProfile = Lists.newArrayList();
             for (TDetailedReportParams param : params.detailed_report) {
@@ -268,6 +269,7 @@ public void updateProfile(TReportExecStatusParams params, TNetworkAddress addres
             }
             multiBeProfile.get(params.fragment_id).put(address, taskProfile);
         } else {
+            LOG.debug("params: {}", params);
             PlanFragmentId fragmentId = instanceIdToFragmentId.get(params.fragment_instance_id);
             if (fragmentId == null) {
                 LOG.warn("Could not find related fragment for instance {}",
@@ -286,6 +288,7 @@ public void updateProfile(TReportExecStatusParams params, TNetworkAddress addres
                 return;
             }
             if (params.isSetProfile()) {
+                LOG.debug("params profile: {}", params.profile);
                 instanceProfile.update(params.profile);
             }
             if (params.isSetDone() && params.isDone()) {

diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/QeProcessorImpl.java b/fe/fe-core/src/main/java/org/apache/doris/qe/QeProcessorImpl.java
@@ -206,7 +206,7 @@ public Map<String, QueryStatisticsItem> getQueryStatistics() {
 
     @Override
     public TReportExecStatusResult reportExecStatus(TReportExecStatusParams params, TNetworkAddress beAddr) {
-        if (params.isSetProfile()) {
+        if (params.isSetProfile() || params.isSetLoadChannelProfile()) {
             LOG.info("ReportExecStatus(): fragment_instance_id={}, query id={}, backend num: {}, ip: {}",
                     DebugUtil.printId(params.fragment_instance_id), DebugUtil.printId(params.query_id),
                     params.backend_num, beAddr);