Skip to content

Commit 8553772

Browse files
committed
Remove several remaining Core/Infra UpdateForV9 uses
1 parent 387eef0 commit 8553772

File tree

3 files changed

+2
-13
lines changed

3 files changed

+2
-13
lines changed

server/src/main/java/org/elasticsearch/TransportVersions.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,6 @@
1010
package org.elasticsearch;
1111

1212
import org.elasticsearch.core.Assertions;
13-
import org.elasticsearch.core.UpdateForV9;
1413

1514
import java.lang.reflect.Field;
1615
import java.util.ArrayList;
@@ -49,7 +48,6 @@ static TransportVersion def(int id) {
4948
return new TransportVersion(id);
5049
}
5150

52-
@UpdateForV9(owner = UpdateForV9.Owner.CORE_INFRA) // remove the transport versions with which v9 will not need to interact
5351
public static final TransportVersion ZERO = def(0);
5452
public static final TransportVersion V_7_0_0 = def(7_00_00_99);
5553
public static final TransportVersion V_7_1_0 = def(7_01_00_99);
@@ -99,8 +97,6 @@ static TransportVersion def(int id) {
9997
public static final TransportVersion V_8_16_1 = def(8_772_0_04);
10098
public static final TransportVersion INITIAL_ELASTICSEARCH_8_16_5 = def(8_772_0_05);
10199
public static final TransportVersion INITIAL_ELASTICSEARCH_8_16_6 = def(8_772_0_06);
102-
public static final TransportVersion REMOVE_MIN_COMPATIBLE_SHARD_NODE = def(8_773_0_00);
103-
public static final TransportVersion REVERT_REMOVE_MIN_COMPATIBLE_SHARD_NODE = def(8_774_0_00);
104100
public static final TransportVersion V_8_17_0 = def(8_797_0_02);
105101
public static final TransportVersion INITIAL_ELASTICSEARCH_8_17_3 = def(8_797_0_03);
106102
public static final TransportVersion INITIAL_ELASTICSEARCH_8_17_4 = def(8_797_0_04);

server/src/test/java/org/elasticsearch/env/NodeEnvironmentTests.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,6 @@
3030
import org.elasticsearch.core.IOUtils;
3131
import org.elasticsearch.core.PathUtils;
3232
import org.elasticsearch.core.SuppressForbidden;
33-
import org.elasticsearch.core.UpdateForV9;
3433
import org.elasticsearch.gateway.MetadataStateFormat;
3534
import org.elasticsearch.gateway.PersistedClusterStateService;
3635
import org.elasticsearch.index.Index;
@@ -539,8 +538,6 @@ public void testBlocksDowngradeToVersionWithMultipleNodesInDataPath() throws IOE
539538
}
540539
}
541540

542-
@UpdateForV9(owner = UpdateForV9.Owner.CORE_INFRA)
543-
@AwaitsFix(bugUrl = "test won't work until we remove and bump minimum index versions")
544541
public void testIndexCompatibilityChecks() throws IOException {
545542
final Settings settings = buildEnvSettings(Settings.EMPTY);
546543

server/src/test/java/org/elasticsearch/transport/OutboundHandlerTests.java

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,6 @@
1212
import org.apache.logging.log4j.Level;
1313
import org.elasticsearch.ElasticsearchException;
1414
import org.elasticsearch.TransportVersion;
15-
import org.elasticsearch.TransportVersions;
1615
import org.elasticsearch.action.ActionListener;
1716
import org.elasticsearch.action.support.PlainActionFuture;
1817
import org.elasticsearch.cluster.node.DiscoveryNode;
@@ -35,7 +34,6 @@
3534
import org.elasticsearch.core.Streams;
3635
import org.elasticsearch.core.TimeValue;
3736
import org.elasticsearch.core.Tuple;
38-
import org.elasticsearch.core.UpdateForV9;
3937
import org.elasticsearch.test.ESTestCase;
4038
import org.elasticsearch.test.MockLog;
4139
import org.elasticsearch.test.TransportVersionUtils;
@@ -141,8 +139,7 @@ public void testSendRequest() throws IOException {
141139
TransportVersion version = isHandshake
142140
? randomFrom(TransportHandshaker.ALLOWED_HANDSHAKE_VERSIONS)
143141
: TransportVersionUtils.randomCompatibleVersion(random());
144-
@UpdateForV9(owner = UpdateForV9.Owner.CORE_INFRA) // drop the version.onOrAfter() in v9
145-
boolean compress = version.onOrAfter(TransportVersions.MINIMUM_COMPATIBLE) && randomBoolean();
142+
boolean compress = randomBoolean();
146143
String value = "message";
147144
threadContext.putHeader("header", "header_value");
148145
TestRequest request = new TestRequest(value);
@@ -215,8 +212,7 @@ public void testSendResponse() throws IOException {
215212
TransportVersion version = isHandshake
216213
? randomFrom(TransportHandshaker.ALLOWED_HANDSHAKE_VERSIONS)
217214
: TransportVersionUtils.randomCompatibleVersion(random());
218-
@UpdateForV9(owner = UpdateForV9.Owner.CORE_INFRA) // drop the version.onOrAfter() in v9
219-
boolean compress = version.onOrAfter(TransportVersions.MINIMUM_COMPATIBLE) && randomBoolean();
215+
boolean compress = randomBoolean();
220216

221217
String value = "message";
222218
threadContext.putHeader("header", "header_value");

0 commit comments

Comments
 (0)