From 764731714bfc2f07dcc5090b977af0e22301ea47 Mon Sep 17 00:00:00 2001 From: "xiaojian.fxj" Date: Tue, 10 Jan 2017 09:42:35 +0800 Subject: [PATCH] the new leader will lost the statistics of the driver's resource on the worker When the leader master has changed. --- .../src/main/scala/org/apache/spark/deploy/master/Master.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/core/src/main/scala/org/apache/spark/deploy/master/Master.scala b/core/src/main/scala/org/apache/spark/deploy/master/Master.scala index c5f7c077fe20..4f98c97df1b4 100644 --- a/core/src/main/scala/org/apache/spark/deploy/master/Master.scala +++ b/core/src/main/scala/org/apache/spark/deploy/master/Master.scala @@ -360,13 +360,14 @@ private[deploy] class Master( val execInfo = app.addExecutor(worker, exec.cores, Some(exec.execId)) worker.addExecutor(execInfo) execInfo.copyState(exec) + app.state = ApplicationState.RUNNING } for (driverId <- driverIds) { drivers.find(_.id == driverId).foreach { driver => driver.worker = Some(worker) driver.state = DriverState.RUNNING - worker.drivers(driverId) = driver + worker.addDriver(driver) } } case None =>