Skip to content
Snippets Groups Projects
Commit 62855131 authored by Patrick Wendell's avatar Patrick Wendell
Browse files

Fix bug in worker clean-up in UI

Introduced in d5a96fec. This should be picked into 0.8 and 0.9 as well.
parent 5316bcac
No related branches found
No related tags found
No related merge requests found
......@@ -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
}
......
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