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

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

Browse Source 
This reverts commit efad5717ec.
This commit is contained in:
Ajay Kumar 2019-03-22 16:20:44 -07:00
parent efad5717ec
commit 771ea6b5e7
2 changed files with 0 additions and 16 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,9 +623,6 @@ 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,19 +332,6 @@ 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);