diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/DynamicCacheChangeRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/DynamicCacheChangeRequest.java index a3116ad98772c..1e5ab8823be75 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/DynamicCacheChangeRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/DynamicCacheChangeRequest.java @@ -35,7 +35,7 @@ public class DynamicCacheChangeRequest implements Serializable { private static final long serialVersionUID = 0L; /** */ - private UUID requestId; + private UUID reqId; /** Start ID. */ private IgniteUuid deploymentId; @@ -95,8 +95,8 @@ public class DynamicCacheChangeRequest implements Serializable { * @param cacheName Cache stop name. * @param initiatingNodeId Initiating node ID. */ - public DynamicCacheChangeRequest(UUID requestId, String cacheName, UUID initiatingNodeId) { - this.requestId = requestId; + public DynamicCacheChangeRequest(UUID reqId, String cacheName, UUID initiatingNodeId) { + this.reqId = reqId; this.cacheName = cacheName; this.initiatingNodeId = initiatingNodeId; } @@ -105,7 +105,7 @@ public DynamicCacheChangeRequest(UUID requestId, String cacheName, UUID initiati * @return Request ID. */ public UUID requestId() { - return requestId; + return reqId; } /** diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java index 1e5fcc1dfe8a2..7f4fb99f60e31 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java @@ -2041,8 +2041,9 @@ private GridCacheSharedContext createSharedContext(GridKernalContext kernalCtx, if (desc == null) continue; - - DynamicCacheChangeRequest req = new DynamicCacheChangeRequest(UUID.randomUUID(), cache.name(), null); + // requestId must be null because on different node will be different byte [] and we get duplicate discovery data + // see TcpDiscoveryNodeAddedMessage#addDiscoveryData 'Arrays.equals(curData, discoDataEntry.getValue())' + DynamicCacheChangeRequest req = new DynamicCacheChangeRequest(null, cache.name(), null); req.startCacheConfiguration(desc.cacheConfiguration()); @@ -2068,7 +2069,7 @@ private GridCacheSharedContext createSharedContext(GridKernalContext kernalCtx, for (DynamicCacheDescriptor desc : registeredCaches.values()) { DynamicCacheChangeRequest req = new DynamicCacheChangeRequest( - UUID.randomUUID(), desc.cacheConfiguration().getName(), null); + null, desc.cacheConfiguration().getName(), null); req.startCacheConfiguration(desc.cacheConfiguration()); @@ -2083,7 +2084,7 @@ private GridCacheSharedContext createSharedContext(GridKernalContext kernalCtx, for (DynamicCacheDescriptor desc : registeredTemplates.values()) { DynamicCacheChangeRequest req = new DynamicCacheChangeRequest( - UUID.randomUUID(), desc.cacheConfiguration().getName(), null); + null, desc.cacheConfiguration().getName(), null); req.startCacheConfiguration(desc.cacheConfiguration()); 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 44159c6b0fd8e..585c153823f74 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 @@ -18,7 +18,6 @@ package org.apache.ignite.spi.discovery.tcp; import java.io.BufferedInputStream; -import java.io.BufferedOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.ObjectStreamException;