From 6504f6de7459892b4d2afa95d6e03b33dfc78471 Mon Sep 17 00:00:00 2001 From: Gabriel Date: Sun, 18 Feb 2024 17:13:02 +0800 Subject: [PATCH] [pipelineX](bug) Fix ConcurrentModificationException for profile reporting (#31040) --- .../src/main/java/org/apache/doris/qe/Coordinator.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) 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)); }