Migrate transport versions 9162_000 through 9158_000

Author: jdconrad

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

@@ -260,11 +260,6 @@ static TransportVersion def(int id) {
     public static final TransportVersion STATE_PARAM_GET_SNAPSHOT = def(9_100_0_00);
     public static final TransportVersion PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP = def(9_101_0_00);
     public static final TransportVersion CLUSTER_STATE_PROJECTS_SETTINGS = def(9_108_0_00);
-    public static final TransportVersion INDEX_SOURCE = def(9_158_0_00);
-    public static final TransportVersion MAX_HEAP_SIZE_PER_NODE_IN_CLUSTER_INFO = def(9_159_0_00);
-    public static final TransportVersion TIMESERIES_DEFAULT_LIMIT = def(9_160_0_00);
-    public static final TransportVersion INFERENCE_API_OPENAI_HEADERS = def(9_161_0_00);
-    public static final TransportVersion NEW_SEMANTIC_QUERY_INTERCEPTORS = def(9_162_0_00);
 
     /*
      * STOP! READ THIS FIRST! No, really,

server/src/main/java/org/elasticsearch/action/index/IndexRequest.java

@@ -75,8 +75,10 @@
 public class IndexRequest extends ReplicatedWriteRequest<IndexRequest> implements DocWriteRequest<IndexRequest>, CompositeIndicesRequest {
 
     private static final long SHALLOW_SIZE = RamUsageEstimator.shallowSizeOfInstance(IndexRequest.class);
+
     private static final TransportVersion PIPELINES_HAVE_RUN_FIELD_ADDED = TransportVersions.V_8_10_X;
     private static final TransportVersion INDEX_REQUEST_INCLUDE_TSID = TransportVersion.fromName("index_request_include_tsid");
+    private static final TransportVersion INDEX_SOURCE = TransportVersion.fromName("index_source");
 
     private static final Supplier<String> ID_GENERATOR = UUIDs::base64UUID;
 
@@ -164,7 +166,7 @@ public IndexRequest(@Nullable ShardId shardId, StreamInput in) throws IOExceptio
         }
         id = in.readOptionalString();
         routing = in.readOptionalString();
-        boolean beforeSourceContext = in.getTransportVersion().before(TransportVersions.INDEX_SOURCE);
+        boolean beforeSourceContext = in.getTransportVersion().supports(INDEX_SOURCE) == false;
         BytesReference source;
         IndexSource localIndexSource = null;
         if (beforeSourceContext) {
@@ -765,7 +767,7 @@ private void writeBody(StreamOutput out) throws IOException {
         }
         out.writeOptionalString(id);
         out.writeOptionalString(routing);
-        if (out.getTransportVersion().onOrAfter(TransportVersions.INDEX_SOURCE)) {
+        if (out.getTransportVersion().supports(INDEX_SOURCE)) {
             indexSource.writeTo(out);
         } else {
             out.writeBytesReference(indexSource.bytes());
@@ -778,7 +780,7 @@ private void writeBody(StreamOutput out) throws IOException {
         out.writeBoolean(isPipelineResolved);
         out.writeBoolean(isRetry);
         out.writeLong(autoGeneratedTimestamp);
-        if (out.getTransportVersion().before(TransportVersions.INDEX_SOURCE)) {
+        if (out.getTransportVersion().supports(INDEX_SOURCE) == false) {
             XContentType contentType = indexSource.contentType();
             if (contentType != null) {
                 out.writeBoolean(true);

server/src/main/java/org/elasticsearch/cluster/ClusterInfo.java

@@ -54,6 +54,9 @@ public class ClusterInfo implements ChunkedToXContent, Writeable, ExpectedShardS
         "node_usage_stats_for_thread_pools_in_cluster_info"
     );
     private static final TransportVersion SHARD_WRITE_LOAD_IN_CLUSTER_INFO = TransportVersion.fromName("shard_write_load_in_cluster_info");
+    private static final TransportVersion MAX_HEAP_SIZE_PER_NODE_IN_CLUSTER_INFO = TransportVersion.fromName(
+        "max_heap_size_per_node_in_cluster_info"
+    );
 
     private final Map<String, DiskUsage> leastAvailableSpaceUsage;
     private final Map<String, DiskUsage> mostAvailableSpaceUsage;
@@ -131,7 +134,7 @@ public ClusterInfo(StreamInput in) throws IOException {
         } else {
             this.shardWriteLoads = Map.of();
         }
-        if (in.getTransportVersion().onOrAfter(TransportVersions.MAX_HEAP_SIZE_PER_NODE_IN_CLUSTER_INFO)) {
+        if (in.getTransportVersion().supports(MAX_HEAP_SIZE_PER_NODE_IN_CLUSTER_INFO)) {
             this.maxHeapSizePerNode = in.readImmutableMap(ByteSizeValue::readFrom);
         } else {
             this.maxHeapSizePerNode = Map.of();
@@ -155,7 +158,7 @@ public void writeTo(StreamOutput out) throws IOException {
         if (out.getTransportVersion().supports(SHARD_WRITE_LOAD_IN_CLUSTER_INFO)) {
             out.writeMap(this.shardWriteLoads, StreamOutput::writeWriteable, StreamOutput::writeDouble);
         }
-        if (out.getTransportVersion().onOrAfter(TransportVersions.MAX_HEAP_SIZE_PER_NODE_IN_CLUSTER_INFO)) {
+        if (out.getTransportVersion().supports(MAX_HEAP_SIZE_PER_NODE_IN_CLUSTER_INFO)) {
             out.writeMap(this.maxHeapSizePerNode, StreamOutput::writeWriteable);
         }
     }

server/src/main/resources/transport/definitions/referable/index_source.csv

@@ -0,0 +1 @@
+9158000

server/src/main/resources/transport/definitions/referable/inference_api_openai_headers.csv

@@ -0,0 +1 @@
+9161000

server/src/main/resources/transport/definitions/referable/max_heap_size_per_node_in_cluster_info.csv

@@ -0,0 +1 @@
+9159000

server/src/main/resources/transport/definitions/referable/new_semantic_query_interceptors.csv

@@ -0,0 +1 @@
+9162000

server/src/main/resources/transport/definitions/referable/timeseries_default_limit.csv

@@ -0,0 +1 @@
+9160000

x-pack/plugin/esql-core/src/main/java/org/elasticsearch/xpack/esql/core/type/DataType.java

@@ -33,7 +33,6 @@
 import java.util.stream.Collectors;
 
 import static java.util.stream.Collectors.toMap;
-import static org.elasticsearch.TransportVersions.INDEX_SOURCE;
 
 /**
  * This enum represents data types the ES|QL query processing layer is able to
@@ -297,9 +296,9 @@ public enum DataType implements Writeable {
     // NOTE: If INDEX_SOURCE somehow gets backported to a version that doesn't actually support these types, we'll be missing validation for
     // mixed/multi clusters with remotes that don't support these types. This is low-ish risk because these types require specific
     // geo functions to turn up in the query, and those types aren't available before 9.2.0 either.
-    GEOHASH(builder().esType("geohash").typeName("GEOHASH").estimatedSize(Long.BYTES).supportedOn(INDEX_SOURCE)),
-    GEOTILE(builder().esType("geotile").typeName("GEOTILE").estimatedSize(Long.BYTES).supportedOn(INDEX_SOURCE)),
-    GEOHEX(builder().esType("geohex").typeName("GEOHEX").estimatedSize(Long.BYTES).supportedOn(INDEX_SOURCE)),
+    GEOHASH(builder().esType("geohash").typeName("GEOHASH").estimatedSize(Long.BYTES).supportedOn(DataTypesTransportVersions.INDEX_SOURCE)),
+    GEOTILE(builder().esType("geotile").typeName("GEOTILE").estimatedSize(Long.BYTES).supportedOn(DataTypesTransportVersions.INDEX_SOURCE)),
+    GEOHEX(builder().esType("geohex").typeName("GEOHEX").estimatedSize(Long.BYTES).supportedOn(DataTypesTransportVersions.INDEX_SOURCE)),
 
     /**
      * Fields with this type represent a Lucene doc id. This field is a bit magic in that:
@@ -322,7 +321,9 @@ public enum DataType implements Writeable {
     // NOTE: If INDEX_SOURCE somehow gets backported to a version that doesn't actually support _tsid, we'll be missing validation for
     // mixed/multi clusters with remotes that don't support these types. This is low-ish risk because _tsid requires specifically being
     // used in `FROM idx METADATA _tsid` or in the `TS` command, which both weren't available before 9.2.0.
-    TSID_DATA_TYPE(builder().esType("_tsid").estimatedSize(Long.BYTES * 2).docValues().supportedOn(INDEX_SOURCE)),
+    TSID_DATA_TYPE(
+        builder().esType("_tsid").estimatedSize(Long.BYTES * 2).docValues().supportedOn(DataTypesTransportVersions.INDEX_SOURCE)
+    ),
     /**
      * Fields with this type are the partial result of running a non-time-series aggregation
      * inside alongside time-series aggregations. These fields are not parsable from the
@@ -971,6 +972,9 @@ Builder underConstruction() {
     }
 
     private static class DataTypesTransportVersions {
+
+        public static final TransportVersion INDEX_SOURCE = TransportVersion.fromName("index_source");
+
         public static final TransportVersion ESQL_DENSE_VECTOR_CREATED_VERSION = TransportVersion.fromName(
             "esql_dense_vector_created_version"
         );

x-pack/plugin/esql/qa/server/src/main/java/org/elasticsearch/xpack/esql/qa/rest/AllSupportedFieldsTestCase.java

@@ -39,7 +39,6 @@
 import java.util.TreeMap;
 import java.util.stream.Collectors;
 
-import static org.elasticsearch.TransportVersions.INDEX_SOURCE;
 import static org.elasticsearch.common.xcontent.support.XContentMapValues.extractValue;
 import static org.elasticsearch.test.ListMatcher.matchesList;
 import static org.elasticsearch.test.MapMatcher.assertMap;
@@ -70,6 +69,8 @@
 public class AllSupportedFieldsTestCase extends ESRestTestCase {
     private static final Logger logger = LogManager.getLogger(FieldExtractorTestCase.class);
 
+    private static final TransportVersion INDEX_SOURCE = TransportVersion.fromName("index_source");
+
     @Rule(order = Integer.MIN_VALUE)
     public ProfileLogger profileLogger = new ProfileLogger();
 
@@ -445,7 +446,7 @@ private Matcher<?> expectedValue(DataType type) {
     }
 
     private Matcher<List<?>> expectedDenseVector(TransportVersion version) {
-        return version.onOrAfter(INDEX_SOURCE) // *after* 9.1
+        return version.supports(INDEX_SOURCE) // *after* 9.1
             ? matchesList().item(0.5).item(10.0).item(5.9999995)
             : matchesList().item(0.04283529).item(0.85670584).item(0.5140235);
     }