diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataStorage.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataStorage.java index 590cd9f579..444f4df2ff 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataStorage.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataStorage.java @@ -335,7 +335,7 @@ public VolumeBuilder prepareVolume(DataNode datanode, VolumeBuilder builder = new VolumeBuilder(this, sd); for (NamespaceInfo nsInfo : nsInfos) { - location.makeBlockPoolDir(nsInfo.getBlockPoolID(), null); + location.makeBlockPoolDir(nsInfo.getBlockPoolID(), datanode.getConf()); final BlockPoolSliceStorage bpStorage = getBlockPoolSliceStorage(nsInfo); final List dirs = bpStorage.loadBpStorageDirectories( @@ -457,7 +457,7 @@ private List loadBlockPoolSliceStorage(DataNode datanode, final List success = Lists.newArrayList(); final List tasks = Lists.newArrayList(); for (StorageLocation dataDir : dataDirs) { - dataDir.makeBlockPoolDir(bpid, null); + dataDir.makeBlockPoolDir(bpid, datanode.getConf()); try { final List> sdCallables = Lists.newArrayList();