Skip to content
Snippets Groups Projects
Commit 4ab387bc authored by Mosharaf Chowdhury's avatar Mosharaf Chowdhury
Browse files

Fixed master datastructure updates after removing an application; and a typo.

parent db9b90fd
No related branches found
No related tags found
No related merge requests found
...@@ -263,7 +263,7 @@ private[spark] class Master(ip: String, port: Int, webUiPort: Int) extends Actor ...@@ -263,7 +263,7 @@ private[spark] class Master(ip: String, port: Int, webUiPort: Int) extends Actor
apps -= app apps -= app
idToApp -= app.id idToApp -= app.id
actorToApp -= app.driver actorToApp -= app.driver
addressToWorker -= app.driver.path.address addressToApp -= app.driver.path.address
completedApps += app // Remember it in our history completedApps += app // Remember it in our history
waitingApps -= app waitingApps -= app
for (exec <- app.executors.values) { for (exec <- app.executors.values) {
......
...@@ -26,7 +26,7 @@ private[spark] class BlockManagerMaster( ...@@ -26,7 +26,7 @@ private[spark] class BlockManagerMaster(
val AKKA_RETRY_ATTEMPTS: Int = System.getProperty("spark.akka.num.retries", "3").toInt val AKKA_RETRY_ATTEMPTS: Int = System.getProperty("spark.akka.num.retries", "3").toInt
val AKKA_RETRY_INTERVAL_MS: Int = System.getProperty("spark.akka.retry.wait", "3000").toInt val AKKA_RETRY_INTERVAL_MS: Int = System.getProperty("spark.akka.retry.wait", "3000").toInt
val DRIVER_AKKA_ACTOR_NAME = "BlockMasterManager" val DRIVER_AKKA_ACTOR_NAME = "BlockManagerMaster"
val timeout = 10.seconds val timeout = 10.seconds
var driverActor: ActorRef = { var driverActor: ActorRef = {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment