database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[pipelineX](bug) Fix ConcurrentModificationException for profile reporting (#31040)

Browse Source
This commit is contained in:
Gabriel
2024-02-18 17:13:02 +08:00
committed by yiguolei
parent 3f126fdd63
commit 6504f6de74
1 changed files with 1 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
View File

@ -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));
}