Repository: incubator-ignite Updated Branches: refs/heads/ignite-1093 dc10b85cc -> b7ee4cc57
ignite-1093 Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/b7ee4cc5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/b7ee4cc5 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/b7ee4cc5 Branch: refs/heads/ignite-1093 Commit: b7ee4cc5760400c4b3e8b75597b6fe55a47c4f34 Parents: dc10b85 Author: Anton Vinogradov <vinogradov.an...@gmail.com> Authored: Fri Aug 21 17:03:54 2015 +0300 Committer: Anton Vinogradov <vinogradov.an...@gmail.com> Committed: Fri Aug 21 17:03:54 2015 +0300 ---------------------------------------------------------------------- .../distributed/dht/preloader/GridDhtPartitionDemander.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7ee4cc5/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java index 126bde9..0c30630 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java @@ -339,10 +339,7 @@ public class GridDhtPartitionDemander { syncFut.append(node.id(), remainings); - int lsnrCnt = cctx.config().getRebalanceThreadPoolSize() / assigns.entrySet().size(); - - if (lsnrCnt == 0) - lsnrCnt = 1;//At least one listener per node. + int lsnrCnt = cctx.config().getRebalanceThreadPoolSize(); List<Set<Integer>> sParts = new ArrayList<>(lsnrCnt);
