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 083d3cd3fd..15165bad15 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 @@ -3995,11 +3995,7 @@ public class Coordinator implements CoordInterface { private void attachInstanceProfileToFragmentProfile() { if (enablePipelineEngine) { for (PipelineExecContext ctx : pipelineExecContexts.values()) { - if (enablePipelineXEngine) { - synchronized (this) { - ctx.attachPipelineProfileToFragmentProfile(); - } - } else { + if (!enablePipelineXEngine) { ctx.profileStream() .forEach(p -> executionProfile.addInstanceProfile(ctx.profileFragmentId, p)); }