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);