apache
diff --git a/‎yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala‎
Lines changed: 1 addition & 1 deletion b/‎yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocationHandler.scala‎
Lines changed: 0 additions & 213 deletions b/‎yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocationHandler.scala‎
Lines changed: 0 additions & 213 deletions
@@ -511,7 +511,7 @@ object ApplicationMaster extends Logging {
     SignalLogger.register(log)
     val amArgs = new ApplicationMasterArguments(args)
     SparkHadoopUtil.get.runAsSparkUser { () =>
-      master = new ApplicationMaster(amArgs, new YarnRMClientImpl(amArgs))
+      master = new ApplicationMaster(amArgs, new YarnRMClient(amArgs))
       System.exit(master.run())
     }
   }
Original file line number	Diff line number	Diff line change
`@@ -511,7 +511,7 @@ object ApplicationMaster extends Logging {`
`511`	`511`	`SignalLogger.register(log)`
`512`	`512`	`val amArgs = new ApplicationMasterArguments(args)`
`513`	`513`	`SparkHadoopUtil.get.runAsSparkUser { () =>`
`514`		`- master = new ApplicationMaster(amArgs, new YarnRMClientImpl(amArgs))`
	`514`	`+ master = new ApplicationMaster(amArgs, new YarnRMClient(amArgs))`
`515`	`515`	`System.exit(master.run())`
`516`	`516`	`}`
`517`	`517`	`}`