Repository: incubator-ignite Updated Branches: refs/heads/ignite-gg-9615 bdd176267 -> cf2ff2d4b
GG-9615 wip Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/cf2ff2d4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/cf2ff2d4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/cf2ff2d4 Branch: refs/heads/ignite-gg-9615 Commit: cf2ff2d4ba1d7d205c03365e8e1ef8bdfe25a09f Parents: bdd1762 Author: Pavel Tupitsyn <ptupit...@gridgain.com> Authored: Wed Jul 15 21:49:50 2015 +0300 Committer: Pavel Tupitsyn <ptupit...@gridgain.com> Committed: Wed Jul 15 21:49:50 2015 +0300 ---------------------------------------------------------------------- .../ignite/internal/processors/service/GridServiceProcessor.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cf2ff2d4/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProcessor.java index bb451c7..26d18a8 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProcessor.java @@ -621,6 +621,10 @@ public class GridServiceProcessor extends GridProcessorAdapter { private void reassign(GridServiceDeployment dep, long topVer) throws IgniteCheckedException { ServiceConfiguration cfg = dep.configuration(); + Object nodeFilter = cfg.getNodeFilter(); + if (nodeFilter != null) + ctx.resource().injectGeneric(nodeFilter); + int totalCnt = cfg.getTotalCount(); int maxPerNodeCnt = cfg.getMaxPerNodeCount(); String cacheName = cfg.getCacheName();
