This is an automated email from the ASF dual-hosted git repository.

nizhikov pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git


The following commit(s) were added to refs/heads/master by this push:
     new 4bb0be056f7 IGNITE-24099 Remove SIZES_VALIDATION_AVAILABLE_SINCE 
(#11808)
4bb0be056f7 is described below

commit 4bb0be056f7c03112a028f733e2be165509db47a
Author: Vladislav Novikov <[email protected]>
AuthorDate: Thu Jan 16 14:02:59 2025 +0300

    IGNITE-24099 Remove SIZES_VALIDATION_AVAILABLE_SINCE (#11808)
---
 .../dht/topology/GridDhtPartitionsStateValidator.java        | 12 ------------
 1 file changed, 12 deletions(-)

diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtPartitionsStateValidator.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtPartitionsStateValidator.java
index d45cc3f9790..ed038b247e5 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtPartitionsStateValidator.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtPartitionsStateValidator.java
@@ -27,7 +27,6 @@ import java.util.Set;
 import java.util.TreeMap;
 import java.util.UUID;
 import org.apache.ignite.IgniteCheckedException;
-import org.apache.ignite.cluster.ClusterNode;
 import org.apache.ignite.events.DiscoveryEvent;
 import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
 import org.apache.ignite.internal.processors.cache.GridCacheSharedContext;
@@ -36,7 +35,6 @@ import 
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.Gri
 import 
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsSingleMessage;
 import org.apache.ignite.internal.util.lang.IgnitePair;
 import org.apache.ignite.internal.util.typedef.internal.SB;
-import org.apache.ignite.lang.IgniteProductVersion;
 import org.jetbrains.annotations.Nullable;
 
 import static org.apache.ignite.events.EventType.EVT_NODE_JOINED;
@@ -46,9 +44,6 @@ import static 
org.apache.ignite.events.EventType.EVT_NODE_JOINED;
  * process.
  */
 public class GridDhtPartitionsStateValidator {
-    /** Version since node is able to send cache sizes in {@link 
GridDhtPartitionsSingleMessage}. */
-    private static final IgniteProductVersion SIZES_VALIDATION_AVAILABLE_SINCE 
= IgniteProductVersion.fromString("2.5.0");
-
     /** Cache shared context. */
     private final GridCacheSharedContext<?, ?> cctx;
 
@@ -91,13 +86,6 @@ public class GridDhtPartitionsStateValidator {
         Map<Integer, Map<UUID, Long>> resUpdCnt = 
validatePartitionsUpdateCounters(top, messages, ignoringNodes);
         Map<Integer, Map<UUID, Long>> resSize = Collections.emptyMap();
 
-        // For sizes validation ignore also nodes which are not able to send 
cache sizes.
-        for (UUID id : messages.keySet()) {
-            ClusterNode node = cctx.discovery().node(id);
-            if (node != null && 
node.version().compareTo(SIZES_VALIDATION_AVAILABLE_SINCE) < 0)
-                ignoringNodes.add(id);
-        }
-
         // Validate cache sizes.
         resSize = validatePartitionsSizes(top, messages, ignoringNodes);
 

Reply via email to