fix workerCount-- Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/72d409c6 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/72d409c6 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/72d409c6
Branch: refs/heads/master Commit: 72d409c6065de1209ad00289f147b0f65accef16 Parents: f918462 Author: Xin Wang <[email protected]> Authored: Thu Feb 18 17:17:57 2016 +0800 Committer: Xin Wang <[email protected]> Committed: Thu Feb 18 17:17:57 2016 +0800 ---------------------------------------------------------------------- .../src/jvm/org/apache/storm/scheduler/DefaultScheduler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/72d409c6/storm-core/src/jvm/org/apache/storm/scheduler/DefaultScheduler.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/org/apache/storm/scheduler/DefaultScheduler.java b/storm-core/src/jvm/org/apache/storm/scheduler/DefaultScheduler.java index 774e8fd..764c198 100644 --- a/storm-core/src/jvm/org/apache/storm/scheduler/DefaultScheduler.java +++ b/storm-core/src/jvm/org/apache/storm/scheduler/DefaultScheduler.java @@ -38,7 +38,7 @@ public class DefaultScheduler implements IScheduler { Integer workerCount = distribution.get(executorCount); if (workerCount != null && workerCount > 0) { slots.add(entry.getKey()); - executorCount--; + workerCount--; distribution.put(executorCount, workerCount); } }
