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

Fixed checkstyle issues.

Browse Source
This commit is contained in:
sdeka 2019-05-20 08:13:37 +05:30
parent 869a1ab41a
commit 64c39856d2
2 changed files with 5 additions and 4 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/ozoneimpl/ContainerReader.java
View File

@ -225,7 +225,8 @@ public void verifyContainerData(ContainerData containerData)
} }
} }
private void initializeUsedBytes(KeyValueContainer container) throws IOException { private void initializeUsedBytes(KeyValueContainer container)
throws IOException {
KeyValueBlockIterator blockIter = new KeyValueBlockIterator( KeyValueBlockIterator blockIter = new KeyValueBlockIterator(
container.getContainerData().getContainerID(), container.getContainerData().getContainerID(),
new File(container.getContainerData().getContainerPath())); new File(container.getContainerData().getContainerPath()));

6
hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/ozoneimpl/TestOzoneContainer.java
View File

@ -70,7 +70,7 @@ public class TestOzoneContainer {
private KeyValueContainer keyValueContainer; private KeyValueContainer keyValueContainer;
private final DatanodeDetails datanodeDetails = createDatanodeDetails(); private final DatanodeDetails datanodeDetails = createDatanodeDetails();
private HashMap<String, Long> commitSpaceMap; //RootDir -> committed space private HashMap<String, Long> commitSpaceMap; //RootDir -> committed space
private final int NUM_TEST_CONTAINERS = 10; private final int numTestContainers = 10;
@Before @Before
public void setUp() throws Exception { public void setUp() throws Exception {
@ -94,7 +94,7 @@ public void testBuildContainerMap() throws Exception {
} }
// Add containers to disk // Add containers to disk
for (int i=0; i < NUM_TEST_CONTAINERS; i++) { for (int i = 0; i < numTestContainers; i++) {
long freeBytes = 0; long freeBytes = 0;
long volCommitBytes; long volCommitBytes;
long maxCap = (long) StorageUnit.GB.toBytes(1); long maxCap = (long) StorageUnit.GB.toBytes(1);
@ -130,7 +130,7 @@ public void testBuildContainerMap() throws Exception {
OzoneContainer(datanodeDetails, conf, context, null); OzoneContainer(datanodeDetails, conf, context, null);
ContainerSet containerset = ozoneContainer.getContainerSet(); ContainerSet containerset = ozoneContainer.getContainerSet();
assertEquals(NUM_TEST_CONTAINERS, containerset.containerCount()); assertEquals(numTestContainers, containerset.containerCount());
verifyCommittedSpace(ozoneContainer); verifyCommittedSpace(ozoneContainer);
} }