improve remove lock log

apache · Jan 4, 2025 · faf0745 · faf0745
1 parent ec398ba
commit faf0745
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/.../hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataSetLockManager.java b/.../hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataSetLockManager.java
@@ -273,6 +273,9 @@ public void removeLock(LockLevel level, String... resources) {
     try (AutoCloseDataSetLock lock = writeLock(level, resources)) {
       lockMap.removeLock(lockName);
     }
+    if (openLockTrace) {
+      LOG.info("Removed {} lock, lock name: {}", level.name(), lockName);
+    }
   }
 
   @Override

diff --git a/...fs/src/main/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/FsDatasetImpl.java b/...fs/src/main/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/FsDatasetImpl.java
@@ -645,8 +645,6 @@ public void removeVolumes(
           List<String> allSubDirNameForDataSetLock = datasetSubLockStrategy.getAllSubLockName();
           for (String dir : allSubDirNameForDataSetLock) {
             lockManager.removeLock(LockLevel.DIR, bp, storageUuid, dir);
-            LOG.info("Removed DIR lock for bpid:{}, volume storageid:{}, dir:{}",
-                bp, storageUuid, dir);
           }
           lockManager.removeLock(LockLevel.VOLUME, bp, storageUuid);
         }