Repository: incubator-gearpump Updated Branches: refs/heads/master c55604f02 -> f6f8903bf
fix GEARPUMP-123, update Worker's executorsInfo on executor down Author: manuzhang <[email protected]> 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 <[email protected]> Authored: Thu May 19 08:51:09 2016 +0800 Committer: huafengw <[email protected]> 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")
