You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by pw...@apache.org on 2014/01/23 04:37:43 UTC
[1/2] git commit: Fix bug in worker clean-up in UI
Updated Branches:
refs/heads/master 034dce2a7 -> a1cd18512
Fix bug in worker clean-up in UI
Introduced in d5a96fec. This should be picked into 0.8 and 0.9 as well.
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/62855131
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/62855131
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/62855131
Branch: refs/heads/master
Commit: 6285513147c78b6bedc9ea21e6f4644b1a71e8f4
Parents: 5316bca
Author: Patrick Wendell <pw...@gmail.com>
Authored: Wed Jan 22 18:19:46 2014 -0800
Committer: Patrick Wendell <pw...@gmail.com>
Committed: Wed Jan 22 18:19:52 2014 -0800
----------------------------------------------------------------------
core/src/main/scala/org/apache/spark/deploy/master/Master.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/62855131/core/src/main/scala/org/apache/spark/deploy/master/Master.scala
----------------------------------------------------------------------
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 d9ea96a..7be7749 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
}
[2/2] git commit: Merge pull request #496 from pwendell/master
Posted by pw...@apache.org.
Merge pull request #496 from pwendell/master
Fix bug in worker clean-up in UI
Introduced in d5a96fec (/cc @aarondav).
This should be picked into 0.8 and 0.9 as well. The bug causes old (zombie) workers on a node to not disappear immediately from the UI when a new one registers.
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/a1cd1851
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/a1cd1851
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/a1cd1851
Branch: refs/heads/master
Commit: a1cd185122602c96fb8ae16c0b506702283bf6e2
Parents: 034dce2 6285513
Author: Patrick Wendell <pw...@gmail.com>
Authored: Wed Jan 22 19:37:29 2014 -0800
Committer: Patrick Wendell <pw...@gmail.com>
Committed: Wed Jan 22 19:37:29 2014 -0800
----------------------------------------------------------------------
core/src/main/scala/org/apache/spark/deploy/master/Master.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/a1cd1851/core/src/main/scala/org/apache/spark/deploy/master/Master.scala
----------------------------------------------------------------------