File tree Expand file tree Collapse file tree 1 file changed +6
-1
lines changed
yarn/src/main/scala/org/apache/spark/scheduler/cluster Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Original file line number Diff line number Diff line change @@ -41,7 +41,6 @@ private[spark] class YarnClientSchedulerBackend(
4141 * This waits until the application is running.
4242 */
4343 override def start () {
44- super .start()
4544 val driverHost = conf.get(" spark.driver.host" )
4645 val driverPort = conf.get(" spark.driver.port" )
4746 val hostport = driverHost + " :" + driverPort
@@ -56,6 +55,12 @@ private[spark] class YarnClientSchedulerBackend(
5655 totalExpectedExecutors = args.numExecutors
5756 client = new Client (args, conf)
5857 appId = client.submitApplication()
58+
59+ // SPARK-8687: Ensure all necessary properties have already been set before
60+ // we initialize our driver scheduler backend, which serves these properties
61+ // to the executors
62+ super .start()
63+
5964 waitForApplication()
6065 monitorThread = asyncMonitorApplication()
6166 monitorThread.start()
You can’t perform that action at this time.
0 commit comments