You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gearpump.apache.org by hu...@apache.org on 2016/05/19 01:09:51 UTC
incubator-gearpump git commit: fix GEARPUMP-123,
update Worker's executorsInfo on executor down
Repository: incubator-gearpump
Updated Branches:
refs/heads/master c55604f02 -> f6f8903bf
fix GEARPUMP-123, update Worker's executorsInfo on executor down
Author: manuzhang <ow...@gmail.com>
Closes #21 from manuzhang/GEARPUMP-123.
Project: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/commit/f6f8903b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/tree/f6f8903b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/diff/f6f8903b
Branch: refs/heads/master
Commit: f6f8903bf54c5a5e49e60543986410d24df57b71
Parents: c55604f
Author: manuzhang <ow...@gmail.com>
Authored: Thu May 19 08:51:09 2016 +0800
Committer: huafengw <fv...@gmail.com>
Committed: Thu May 19 08:51:09 2016 +0800
----------------------------------------------------------------------
.../src/main/scala/org/apache/gearpump/cluster/worker/Worker.scala | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-gearpump/blob/f6f8903b/daemon/src/main/scala/org/apache/gearpump/cluster/worker/Worker.scala
----------------------------------------------------------------------
diff --git a/daemon/src/main/scala/org/apache/gearpump/cluster/worker/Worker.scala b/daemon/src/main/scala/org/apache/gearpump/cluster/worker/Worker.scala
index b290938..5ec8644 100644
--- a/daemon/src/main/scala/org/apache/gearpump/cluster/worker/Worker.scala
+++ b/daemon/src/main/scala/org/apache/gearpump/cluster/worker/Worker.scala
@@ -214,6 +214,7 @@ private[cluster] class Worker(masterProxy: ActorRef) extends Actor with TimeOutS
reportResourceToMaster()
if (usedResource == Resource(0)) {
+ executorsInfo -= executor
allocatedResources -= executor
// stop executor if there is no resource binded to it.
LOG.info(s"Shutdown executor $executorId because the resource used is zero")