bug fix: core-site.xml config ignored

exacaster · Feb 3, 2022 · a12c7b1 · a12c7b1
1 parent 3cfa925
commit a12c7b1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/server/src/main/java/com/exacaster/lighter/backend/yarn/YarnConfigurationFactory.java b/server/src/main/java/com/exacaster/lighter/backend/yarn/YarnConfigurationFactory.java
@@ -8,9 +8,9 @@
 import io.micronaut.context.annotation.Property;
 import io.micronaut.context.annotation.Requires;
 import jakarta.inject.Singleton;
+import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.yarn.client.api.YarnClient;
-import org.apache.hadoop.yarn.conf.YarnConfiguration;
 
 @Factory
 @Requires(beans = YarnProperties.class)
@@ -19,7 +19,7 @@ public class YarnConfigurationFactory {
     @Singleton
     public YarnBackend backend(YarnProperties yarnProperties, AppConfiguration conf,
             @Property(name = "hadoop.conf.dir") String hadoopConfDir) {
-        YarnConfiguration yarnConfiguration = new YarnConfiguration();
+        var yarnConfiguration = new Configuration(false);
         yarnConfiguration.addResource(new Path(hadoopConfDir, "core-site.xml"));
         yarnConfiguration.addResource(new Path(hadoopConfDir, "yarn-site.xml"));
         if (yarnProperties.getKerberosKeytab() != null && yarnProperties.getKerberosPrincipal() != null) {