This is an automated email from the ASF dual-hosted git repository.
bharat pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new e094b3b HDDS-1680. Create missing parent directories during the
creation of HddsVolume dirs (#961)
e094b3b is described below
commit e094b3b4cd15fe9cd309884bc27a973bf9e4eb6b
Author: Elek, Márton <[email protected]>
AuthorDate: Fri Jun 14 01:18:15 2019 +0200
HDDS-1680. Create missing parent directories during the creation of
HddsVolume dirs (#961)
---
.../org/apache/hadoop/ozone/container/common/volume/HddsVolume.java | 2 +-
.../org/apache/hadoop/ozone/container/common/volume/TestVolumeSet.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/volume/HddsVolume.java
b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/volume/HddsVolume.java
index 4eb16c1..3e89f90 100644
---
a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/volume/HddsVolume.java
+++
b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/volume/HddsVolume.java
@@ -204,7 +204,7 @@ public class HddsVolume
switch (intialVolumeState) {
case NON_EXISTENT:
// Root directory does not exist. Create it.
- if (!hddsRootDir.mkdir()) {
+ if (!hddsRootDir.mkdirs()) {
throw new IOException("Cannot create directory " + hddsRootDir);
}
setState(VolumeState.NOT_FORMATTED);
diff --git
a/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/common/volume/TestVolumeSet.java
b/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/common/volume/TestVolumeSet.java
index 79eeb61..fa280dd 100644
---
a/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/common/volume/TestVolumeSet.java
+++
b/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/common/volume/TestVolumeSet.java
@@ -230,7 +230,7 @@ public class TestVolumeSet {
ozoneConfig.set(HDDS_DATANODE_DIR_KEY, readOnlyVolumePath.getAbsolutePath()
+ "," + volumePath.getAbsolutePath());
volSet = new VolumeSet(UUID.randomUUID().toString(), ozoneConfig);
- assertTrue(volSet.getFailedVolumesList().size() == 1);
+ assertEquals(1, volSet.getFailedVolumesList().size());
assertEquals(readOnlyVolumePath, volSet.getFailedVolumesList().get(0)
.getHddsRootDir());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
