Browse Source

HDFS-17607. Reduce the number of times conf is loaded when DataNode startUp (#7012). Contributed by lei w.

Signed-off-by: He Xiaoqiao <hexiaoqiao@apache.org>
Lei313 6 months ago
parent
commit
e4789a2fd3

+ 2 - 2
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataStorage.java

@@ -335,7 +335,7 @@ public class DataStorage extends Storage {
     VolumeBuilder builder =
     VolumeBuilder builder =
         new VolumeBuilder(this, sd);
         new VolumeBuilder(this, sd);
     for (NamespaceInfo nsInfo : nsInfos) {
     for (NamespaceInfo nsInfo : nsInfos) {
-      location.makeBlockPoolDir(nsInfo.getBlockPoolID(), null);
+      location.makeBlockPoolDir(nsInfo.getBlockPoolID(), datanode.getConf());
 
 
       final BlockPoolSliceStorage bpStorage = getBlockPoolSliceStorage(nsInfo);
       final BlockPoolSliceStorage bpStorage = getBlockPoolSliceStorage(nsInfo);
       final List<StorageDirectory> dirs = bpStorage.loadBpStorageDirectories(
       final List<StorageDirectory> dirs = bpStorage.loadBpStorageDirectories(
@@ -457,7 +457,7 @@ public class DataStorage extends Storage {
     final List<StorageDirectory> success = Lists.newArrayList();
     final List<StorageDirectory> success = Lists.newArrayList();
     final List<UpgradeTask> tasks = Lists.newArrayList();
     final List<UpgradeTask> tasks = Lists.newArrayList();
     for (StorageLocation dataDir : dataDirs) {
     for (StorageLocation dataDir : dataDirs) {
-      dataDir.makeBlockPoolDir(bpid, null);
+      dataDir.makeBlockPoolDir(bpid, datanode.getConf());
       try {
       try {
         final List<Callable<StorageDirectory>> sdCallables =
         final List<Callable<StorageDirectory>> sdCallables =
             Lists.newArrayList();
             Lists.newArrayList();