From 4636b9723733cb54332eca06e9d79e2a8181c8fb Mon Sep 17 00:00:00 2001
From: yiguolei <yiguolei@gmail.com>
Date: Sat, 30 Mar 2024 16:14:38 +0800
Subject: [PATCH] f

---
 .../java/org/apache/doris/common/profile/ExecutionProfile.java | 3 +++
 .../src/main/java/org/apache/doris/qe/QeProcessorImpl.java     | 2 +-
 2 files changed, 4 insertions(+), 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
index f339da82924e2a7..63a0c9eb82a5415 100644
--- 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
index 27a94013c606621..a62f1b66f084520 100644
--- 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);