summaryrefslogtreecommitdiff
path: root/core/src/test/java/org/elasticsearch/cluster/node/DiscoveryNodeTests.java
diff options
context:
space:
mode:
Diffstat (limited to 'core/src/test/java/org/elasticsearch/cluster/node/DiscoveryNodeTests.java')
-rw-r--r--core/src/test/java/org/elasticsearch/cluster/node/DiscoveryNodeTests.java8
1 files changed, 5 insertions, 3 deletions
diff --git a/core/src/test/java/org/elasticsearch/cluster/node/DiscoveryNodeTests.java b/core/src/test/java/org/elasticsearch/cluster/node/DiscoveryNodeTests.java
index 548f9d407c..91b7a18236 100644
--- a/core/src/test/java/org/elasticsearch/cluster/node/DiscoveryNodeTests.java
+++ b/core/src/test/java/org/elasticsearch/cluster/node/DiscoveryNodeTests.java
@@ -76,8 +76,10 @@ public class DiscoveryNodeTests extends ESTestCase {
assertEquals(transportAddress.getAddress(), serialized.getHostAddress());
assertEquals(transportAddress.getAddress(), serialized.getAddress().getAddress());
assertEquals(transportAddress.getPort(), serialized.getAddress().getPort());
- assertFalse("if the minimum compatibility version moves past 5.0.3, remove the special casing in DiscoverNode(StreamInput) and " +
- "the TransportAddress(StreamInput, String) constructor",
- Version.CURRENT.minimumCompatibilityVersion().onOrAfter(Version.V_5_0_3_UNRELEASED));
+ assertFalse("if the minimum index compatibility version moves past 5.0.3, remove the special casing in DiscoverNode(StreamInput)" +
+ " and the TransportAddress(StreamInput, String) constructor",
+ Version.CURRENT.minimumIndexCompatibilityVersion().after(Version.V_5_0_2));
+ // serialization can happen from an old cluster-state in a full cluster restart
+ // hence we need to maintain this until we drop index bwc
}
}