Repository: ignite Updated Branches: refs/heads/ignite-4154 17229b635 -> 85475c0c8
ignite-4154 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/85475c0c Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/85475c0c Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/85475c0c Branch: refs/heads/ignite-4154 Commit: 85475c0c8322d6d4265d4157e7617788724bb3a8 Parents: 17229b6 Author: sboikov <[email protected]> Authored: Wed Nov 9 14:08:16 2016 +0300 Committer: sboikov <[email protected]> Committed: Wed Nov 9 14:08:16 2016 +0300 ---------------------------------------------------------------------- .../ignite/internal/processors/cache/DynamicCacheChangeBatch.java | 2 +- .../main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java | 3 +-- 2 files changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/85475c0c/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/DynamicCacheChangeBatch.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/DynamicCacheChangeBatch.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/DynamicCacheChangeBatch.java index 39e1c50..4dcff9b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/DynamicCacheChangeBatch.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/DynamicCacheChangeBatch.java @@ -86,7 +86,7 @@ public class DynamicCacheChangeBatch implements DiscoveryCustomMessage { * @param clientNodes Client nodes map. */ public void clientNodes(Map<String, Map<UUID, Boolean>> clientNodes) { - this.clientNodes = null;//clientNodes; + this.clientNodes = clientNodes; } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/85475c0c/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java index 725e71c..6df9d4e 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java @@ -4070,8 +4070,7 @@ class ServerImpl extends TcpDiscoveryImpl { Map<Integer, byte[]> data = msg.newNodeDiscoveryData(); if (data != null) - spi.onExchange(node.id(), node.id(), data, - U.resolveClassLoader(spi.ignite().configuration())); + spi.onExchange(node.id(), node.id(), data, U.resolveClassLoader(spi.ignite().configuration())); msg.addDiscoveryData(locNodeId, spi.collectExchangeData(node.id()));
