diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadLoadingTask.java b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadLoadingTask.java index ef7a07cb9a..2d1b312fb8 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadLoadingTask.java +++ b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadLoadingTask.java @@ -139,10 +139,12 @@ public class LoadLoadingTask extends LoadTask { } private void executeOnce() throws Exception { + final boolean enabelProfile = this.jobProfile != null; // New one query id, Coordinator curCoordinator = new Coordinator(callback.getCallbackId(), loadId, planner.getDescTable(), - planner.getFragments(), planner.getScanNodes(), planner.getTimezone(), loadZeroTolerance); - if (this.jobProfile != null) { + planner.getFragments(), planner.getScanNodes(), planner.getTimezone(), loadZeroTolerance, + enabelProfile); + if (enabelProfile) { this.jobProfile.addExecutionProfile(curCoordinator.getExecutionProfile()); } curCoordinator.setQueryType(TQueryType.LOAD); diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java index bd777c5be6..540c3598d0 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java @@ -357,12 +357,12 @@ public class Coordinator implements CoordInterface { nextInstanceId.setLo(queryId.lo + 1); this.assignedRuntimeFilters = planner.getRuntimeFilters(); this.executionProfile = new ExecutionProfile(queryId, fragments); - } // Used for broker load task/export task/update coordinator + // Constructor of Coordinator is too complicated. public Coordinator(Long jobId, TUniqueId queryId, DescriptorTable descTable, List fragments, - List scanNodes, String timezone, boolean loadZeroTolerance) { + List scanNodes, String timezone, boolean loadZeroTolerance, boolean enableProfile) { this.isBlockQuery = true; this.jobId = jobId; this.queryId = queryId; @@ -370,6 +370,7 @@ public class Coordinator implements CoordInterface { this.fragments = fragments; this.scanNodes = scanNodes; this.queryOptions = new TQueryOptions(); + this.queryOptions.setEnableProfile(enableProfile); this.queryGlobals.setNowString(TimeUtils.DATETIME_FORMAT.format(LocalDateTime.now())); this.queryGlobals.setTimestampMs(System.currentTimeMillis()); this.queryGlobals.setTimeZone(timezone);