소스 검색

Add synchronized on lockLeakCheck() because threadCountMap is not thread safe. (#6029)

Co-authored-by: lgh <liuguanghua@kanzhun.com>
LiuGuH 1 년 전
부모
커밋
335587df9e
1개의 변경된 파일1개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataSetLockManager.java

+ 1 - 1
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataSetLockManager.java

@@ -256,7 +256,7 @@ public class DataSetLockManager implements DataNodeLockManager<AutoCloseDataSetL
     threadCountMap.putIfAbsent(thread, new TrackLog(thread));
   }
 
-  public void lockLeakCheck() {
+  public synchronized void lockLeakCheck() {
     if (!openLockTrace) {
       LOG.warn("not open lock leak check func");
       return;