diff options
| author | Charles Reiss <charles@eecs.berkeley.edu> | 2012-12-05 22:56:52 -0800 |
|---|---|---|
| committer | Charles Reiss <charles@eecs.berkeley.edu> | 2012-12-05 23:35:20 -0800 |
| commit | 813ac7145954f5963362f7a9b35e4e123174bb9d (patch) | |
| tree | 3ee8081444e1e07ca2e2334937f3bf5b6f6307c3 | |
| parent | ddf6cd012c8860e6f66d4988f14a568f2c7edeaa (diff) | |
| download | spark-813ac7145954f5963362f7a9b35e4e123174bb9d.tar.gz spark-813ac7145954f5963362f7a9b35e4e123174bb9d.tar.bz2 spark-813ac7145954f5963362f7a9b35e4e123174bb9d.zip | |
Don't use bogus port number in notifyADeadHost().
| -rw-r--r-- | core/src/main/scala/spark/storage/BlockManagerMaster.scala | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/storage/BlockManagerMaster.scala b/core/src/main/scala/spark/storage/BlockManagerMaster.scala index ace27e758c..0d88c63d89 100644 --- a/core/src/main/scala/spark/storage/BlockManagerMaster.scala +++ b/core/src/main/scala/spark/storage/BlockManagerMaster.scala @@ -361,7 +361,6 @@ private[spark] class BlockManagerMaster(actorSystem: ActorSystem, isMaster: Bool val DEFAULT_MASTER_IP: String = System.getProperty("spark.master.host", "localhost") val DEFAULT_MASTER_PORT: Int = System.getProperty("spark.master.port", "7077").toInt val DEFAULT_MANAGER_IP: String = Utils.localHostName() - val DEFAULT_MANAGER_PORT: String = "10902" val timeout = 10.seconds var masterActor: ActorRef = null @@ -405,7 +404,7 @@ private[spark] class BlockManagerMaster(actorSystem: ActorSystem, isMaster: Bool } def notifyADeadHost(host: String) { - communicate(RemoveHost(host + ":" + DEFAULT_MANAGER_PORT)) + communicate(RemoveHost(host)) logInfo("Removed " + host + " successfully in notifyADeadHost") } |