From a12c7b1c50908603ec4c8f210b887f1bf110d723 Mon Sep 17 00:00:00 2001
From: Denisas <denisas.zeromskis@exacaster.com>
Date: Thu, 3 Feb 2022 21:22:56 +0200
Subject: [PATCH] bug fix: core-site.xml config ignored

---
 .../lighter/backend/yarn/YarnConfigurationFactory.java        | 4 ++--
 1 file changed, 2 insertions(+), 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
index 9bd9d0ba..d0aef42f 100644
--- 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) {