From 6285513147c78b6bedc9ea21e6f4644b1a71e8f4 Mon Sep 17 00:00:00 2001 From: Patrick Wendell Date: Wed, 22 Jan 2014 18:19:46 -0800 Subject: [PATCH] Fix bug in worker clean-up in UI Introduced in d5a96fec. This should be picked into 0.8 and 0.9 as well. --- core/src/main/scala/org/apache/spark/deploy/master/Master.scala | 2 +- 1 file changed, 1 insertion(+), 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 d9ea96afcf..7be774980a 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 @@ -515,7 +515,7 @@ private[spark] class Master(host: String, port: Int, webUiPort: Int) extends Act // There may be one or more refs to dead workers on this same node (w/ different ID's), // remove them. workers.filter { w => - (w.host == host && w.port == port) && (w.state == WorkerState.DEAD) + (w.host == worker.host && w.port == worker.port) && (w.state == WorkerState.DEAD) }.foreach { w => workers -= w }