diff --git a/fe/fe-core/src/main/java/com/starrocks/qe/Coordinator.java b/fe/fe-core/src/main/java/com/starrocks/qe/Coordinator.java index 4c3bf85d4e86b..2d5639c1f69a8 100644 --- a/fe/fe-core/src/main/java/com/starrocks/qe/Coordinator.java +++ b/fe/fe-core/src/main/java/com/starrocks/qe/Coordinator.java @@ -698,7 +698,9 @@ private void prepareResultSink() throws Exception { } else { // This is a load process. - this.queryOptions.setEnable_profile(true); + if (!coordinatorPreprocessor.isUsePipeline()) { + this.queryOptions.setEnable_profile(true); + } deltaUrls = Lists.newArrayList(); loadCounters = Maps.newHashMap(); List relatedBackendIds = Lists.newArrayList(coordinatorPreprocessor.getAddressToBackendID().values());