You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by yi...@apache.org on 2024/02/19 09:24:05 UTC
(doris) 05/18: [pipelineX](bug) Fix ConcurrentModificationException for profile reporting (#31040)
This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 6504f6de7459892b4d2afa95d6e03b33dfc78471
Author: Gabriel <ga...@gmail.com>
AuthorDate: Sun Feb 18 17:13:02 2024 +0800
[pipelineX](bug) Fix ConcurrentModificationException for profile reporting (#31040)
---
fe/fe-core/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 083d3cd3fd8..15165bad159 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));
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org