big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HDDS-661. When a volume fails in datanode, VersionEndpointTask#call ends up in dead lock. Contributed by Hanisha Koneru.

Browse Source
This commit is contained in:
Nandakumar 2018-10-17 18:44:05 +05:30
parent 50715c0699
commit d54f5598f4
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/states/endpoint/VersionEndpointTask.java
View File

@ -75,7 +75,7 @@ public EndpointStateMachine.EndPointStates call() throws Exception {
// Check volumes // Check volumes
VolumeSet volumeSet = ozoneContainer.getVolumeSet(); VolumeSet volumeSet = ozoneContainer.getVolumeSet();
volumeSet.readLock(); volumeSet.writeLock();
try { try {
Map<String, HddsVolume> volumeMap = volumeSet.getVolumeMap(); Map<String, HddsVolume> volumeMap = volumeSet.getVolumeMap();
@ -94,12 +94,12 @@ public EndpointStateMachine.EndPointStates call() throws Exception {
} }
} }
if (volumeSet.getVolumesList().size() == 0) { if (volumeSet.getVolumesList().size() == 0) {
// All volumes are inconsistent state // All volumes are in inconsistent state
throw new DiskOutOfSpaceException("All configured Volumes are in " + throw new DiskOutOfSpaceException("All configured Volumes are in " +
"Inconsistent State"); "Inconsistent State");
} }
} finally { } finally {
volumeSet.readUnlock(); volumeSet.writeUnlock();
} }
ozoneContainer.getDispatcher().setScmId(scmId); ozoneContainer.getDispatcher().setScmId(scmId);