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

HDDS-1310. In datanode once a container becomes unhealthy, datanode restart fails. Contributed by Sandeep Nemuri.

Browse Source
This commit is contained in:
Ajay Kumar 2019-03-22 15:53:12 -07:00
parent 73f7b04e2b
commit efad5717ec
2 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/keyvalue/KeyValueContainer.java
View File

@ -623,6 +623,9 @@ private ContainerReplicaProto.State getHddsState()
case CLOSED: case CLOSED:
state = ContainerReplicaProto.State.CLOSED; state = ContainerReplicaProto.State.CLOSED;
break; break;
case UNHEALTHY:
state = ContainerReplicaProto.State.UNHEALTHY;
break;
default: default:
throw new StorageContainerException("Invalid Container state found: " + throw new StorageContainerException("Invalid Container state found: " +
containerData.getContainerID(), INVALID_CONTAINER_STATE); containerData.getContainerID(), INVALID_CONTAINER_STATE);

13
hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/keyvalue/TestKeyValueContainer.java
View File

@ -332,6 +332,19 @@ public void testCloseContainer() throws Exception {
keyValueContainerData.getState()); keyValueContainerData.getState());
} }
@Test
public void testReportOfUnhealthyContainer() throws Exception {
keyValueContainer.create(volumeSet, volumeChoosingPolicy, scmId);
Assert.assertNotNull(keyValueContainer.getContainerReport());
keyValueContainer.markContainerUnhealthy();
File containerFile = keyValueContainer.getContainerFile();
keyValueContainerData = (KeyValueContainerData) ContainerDataYaml
.readContainerFile(containerFile);
assertEquals(ContainerProtos.ContainerDataProto.State.UNHEALTHY,
keyValueContainerData.getState());
Assert.assertNotNull(keyValueContainer.getContainerReport());
}
@Test @Test
public void testUpdateContainer() throws IOException { public void testUpdateContainer() throws IOException {
keyValueContainer.create(volumeSet, volumeChoosingPolicy, scmId); keyValueContainer.create(volumeSet, volumeChoosingPolicy, scmId);