Skip to content

Commit ce5e44c

Browse files
authored
[improve](common) Add synchronized to avoid concurrent modification #42384 (#42453)
cherry pick from #42384
1 parent c8b1f75 commit ce5e44c

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

fe/fe-core/src/main/java/org/apache/doris/common/MarkedCountDownLatch.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ public MarkedCountDownLatch(int count) {
3535
marks = HashMultimap.create();
3636
}
3737

38-
public void addMark(K key, V value) {
38+
public synchronized void addMark(K key, V value) {
3939
marks.put(key, value);
4040
}
4141

@@ -51,7 +51,7 @@ public synchronized List<Entry<K, V>> getLeftMarks() {
5151
return Lists.newArrayList(marks.entries());
5252
}
5353

54-
public Status getStatus() {
54+
public synchronized Status getStatus() {
5555
return st;
5656
}
5757

0 commit comments

Comments
 (0)