Răsfoiți Sursa

Revert yarn-site.conf related

Tianjin Gu 10 ani în urmă
părinte
comite
02807fb

+ 1 - 1
apps/spark/java/livy-server/src/main/scala/com/cloudera/hue/livy/server/batch/BatchSessionYarn.scala

@@ -21,7 +21,7 @@ package com.cloudera.hue.livy.server.batch
 import java.lang.ProcessBuilder.Redirect
 
 import com.cloudera.hue.livy.sessions._
-import com.cloudera.hue.livy.spark.SparkSubmitProcessBuilder.{RelativePath,  AbsolutePath}
+import com.cloudera.hue.livy.spark.SparkSubmitProcessBuilder.RelativePath
 import com.cloudera.hue.livy.{LineBufferedProcess, LivyConf}
 import com.cloudera.hue.livy.spark.SparkSubmitProcessBuilder
 import com.cloudera.hue.livy.yarn._

+ 0 - 5
apps/spark/java/livy-yarn/src/main/scala/com/cloudera/hue/livy/yarn/Client.scala

@@ -26,7 +26,6 @@ import org.apache.hadoop.yarn.api.records.{ApplicationId, FinalApplicationStatus
 import org.apache.hadoop.yarn.client.api.YarnClient
 import org.apache.hadoop.yarn.conf.YarnConfiguration
 import org.apache.hadoop.yarn.util.ConverterUtils
-import org.apache.hadoop.fs.Path
 
 import scala.annotation.tailrec
 import scala.concurrent.ExecutionContext
@@ -52,10 +51,6 @@ class Client(livyConf: LivyConf) extends Logging {
 
   private[this] val yarnConf = new YarnConfiguration()
   private[this] val yarnClient = YarnClient.createYarnClient()
-  val path = new Path(sys.env("HADOOP_CONF_DIR") + YarnConfiguration.YARN_SITE_CONFIGURATION_FILE)
-  yarnConf.addResource(path)
-  val rm_address = yarnConf.get(YarnConfiguration.RM_ADDRESS)
-  info(s"Resource Manager address: $rm_address")
   yarnClient.init(yarnConf)
   yarnClient.start()