init ErasureCodingPolicyManager

LiuGuH · LiuGuH · commit 48fd51f11cf8 · 2025-05-08T20:31:58.000+08:00
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/tools/offlineImageViewer/FSImageLoader.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/tools/offlineImageViewer/FSImageLoader.java
@@ -246,10 +246,11 @@ static ErasureCodingPolicyManager loadErasureCodingSection(InputStream in) throw
     for (int i = 0; i < s.getPoliciesCount(); ++i) {
       ecPolicies.add(PBHelperClient.convertErasureCodingPolicyInfo(s.getPolicies(i)));
     }
-
+    Configuration conf = new Configuration();
     ErasureCodingPolicyManager erasureCodingPolicyManager =
         ErasureCodingPolicyManager.getInstance();
-    erasureCodingPolicyManager.loadPolicies(ecPolicies, new Configuration());
+    erasureCodingPolicyManager.init(conf);
+    erasureCodingPolicyManager.loadPolicies(ecPolicies, conf);
     return erasureCodingPolicyManager;
   }
 

Original file line number	Diff line number	Diff line change
`@@ -246,10 +246,11 @@ static ErasureCodingPolicyManager loadErasureCodingSection(InputStream in) throw`
`246`	`246`	`for (int i = 0; i < s.getPoliciesCount(); ++i) {`
`247`	`247`	`ecPolicies.add(PBHelperClient.convertErasureCodingPolicyInfo(s.getPolicies(i)));`
`248`	`248`	`}`
`249`		`-`
	`249`	`+ Configuration conf = new Configuration();`
`250`	`250`	`ErasureCodingPolicyManager erasureCodingPolicyManager =`
`251`	`251`	`ErasureCodingPolicyManager.getInstance();`
`252`		`- erasureCodingPolicyManager.loadPolicies(ecPolicies, new Configuration());`
	`252`	`+ erasureCodingPolicyManager.init(conf);`
	`253`	`+ erasureCodingPolicyManager.loadPolicies(ecPolicies, conf);`
`253`	`254`	`return erasureCodingPolicyManager;`
`254`	`255`	`}`
`255`	`256`