IGNITE-6460 Fixed consistentId used in lightweight ClusterNode. Fixes #2707
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/db96b790 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/db96b790 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/db96b790 Branch: refs/heads/ignite-3478 Commit: db96b79008cd63fa8fab17c120ee0d71162c2c78 Parents: ea0dcc4 Author: Eduard Shangareev <eduard.shangar...@gmail.com> Authored: Thu Sep 21 18:55:00 2017 +0300 Committer: Alexey Goncharuk <alexey.goncha...@gmail.com> Committed: Thu Sep 21 18:56:40 2017 +0300 ---------------------------------------------------------------------- .../ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/db96b790/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java index b2797a40..20fb6c5 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java @@ -652,7 +652,7 @@ public class TcpDiscoveryNode extends GridMetadataAwareAdapter implements Cluste /** * IMPORTANT! - * Only purpose of this constructor is creating node which contains only necessary data to store on disc + * Only purpose of this constructor is creating node which contains necessary data to store on disc only * @param node to copy data from */ public TcpDiscoveryNode( @@ -667,6 +667,6 @@ public class TcpDiscoveryNode extends GridMetadataAwareAdapter implements Cluste this.daemon = node.isDaemon(); this.clientRouterNodeId = node.isClient() ? node.id() : null; - attrs = Collections.emptyMap(); + attrs = Collections.singletonMap(ATTR_NODE_CONSISTENT_ID, consistentId); } }