|
27 | 27 | import java.util.TreeMap; |
28 | 28 | import java.util.UUID; |
29 | 29 | import org.apache.ignite.IgniteCheckedException; |
30 | | -import org.apache.ignite.cluster.ClusterNode; |
31 | 30 | import org.apache.ignite.events.DiscoveryEvent; |
32 | 31 | import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion; |
33 | 32 | import org.apache.ignite.internal.processors.cache.GridCacheSharedContext; |
|
36 | 35 | import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsSingleMessage; |
37 | 36 | import org.apache.ignite.internal.util.lang.IgnitePair; |
38 | 37 | import org.apache.ignite.internal.util.typedef.internal.SB; |
39 | | -import org.apache.ignite.lang.IgniteProductVersion; |
40 | 38 | import org.jetbrains.annotations.Nullable; |
41 | 39 |
|
42 | 40 | import static org.apache.ignite.events.EventType.EVT_NODE_JOINED; |
|
46 | 44 | * process. |
47 | 45 | */ |
48 | 46 | public class GridDhtPartitionsStateValidator { |
49 | | - /** Version since node is able to send cache sizes in {@link GridDhtPartitionsSingleMessage}. */ |
50 | | - private static final IgniteProductVersion SIZES_VALIDATION_AVAILABLE_SINCE = IgniteProductVersion.fromString("2.5.0"); |
51 | | - |
52 | 47 | /** Cache shared context. */ |
53 | 48 | private final GridCacheSharedContext<?, ?> cctx; |
54 | 49 |
|
@@ -91,13 +86,6 @@ public void validatePartitionCountersAndSizes( |
91 | 86 | Map<Integer, Map<UUID, Long>> resUpdCnt = validatePartitionsUpdateCounters(top, messages, ignoringNodes); |
92 | 87 | Map<Integer, Map<UUID, Long>> resSize = Collections.emptyMap(); |
93 | 88 |
|
94 | | - // For sizes validation ignore also nodes which are not able to send cache sizes. |
95 | | - for (UUID id : messages.keySet()) { |
96 | | - ClusterNode node = cctx.discovery().node(id); |
97 | | - if (node != null && node.version().compareTo(SIZES_VALIDATION_AVAILABLE_SINCE) < 0) |
98 | | - ignoringNodes.add(id); |
99 | | - } |
100 | | - |
101 | 89 | // Validate cache sizes. |
102 | 90 | resSize = validatePartitionsSizes(top, messages, ignoringNodes); |
103 | 91 |
|
|
0 commit comments