Skip to content

Commit e1264bb

Browse files
committed
fix bug
1 parent 45aeb09 commit e1264bb

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -168,7 +168,7 @@ public AutoCloseDataSetLock readLock(LockLevel level, String... resources) {
168168
AutoCloseDataSetLock bpLock = getReadLock(LockLevel.BLOCK_POOl, resources[0]);
169169
AutoCloseDataSetLock volLock = getReadLock(LockLevel.VOLUME, resources[0], resources[1]);
170170
volLock.setParentLock(bpLock);
171-
AutoCloseDataSetLock dirLock = getWriteLock(level, resources);
171+
AutoCloseDataSetLock dirLock = getReadLock(level, resources);
172172
dirLock.setParentLock(volLock);
173173
if (openLockTrace) {
174174
LOG.debug("Sub lock " + resources[0] + resources[1] + resources[2] + " parent lock " +
@@ -195,7 +195,7 @@ public AutoCloseDataSetLock writeLock(LockLevel level, String... resources) {
195195
AutoCloseDataSetLock bpLock = getReadLock(LockLevel.BLOCK_POOl, resources[0]);
196196
AutoCloseDataSetLock volLock = getReadLock(LockLevel.VOLUME, resources[0], resources[1]);
197197
volLock.setParentLock(bpLock);
198-
AutoCloseDataSetLock dirLock = getReadLock(level, resources);
198+
AutoCloseDataSetLock dirLock = getWriteLock(level, resources);
199199
dirLock.setParentLock(volLock);
200200
if (openLockTrace) {
201201
LOG.debug("Sub lock " + resources[0] + resources[1] + resources[2] + " parent lock " +

0 commit comments

Comments
 (0)