diff --git a/server/src/main/java/org/elasticsearch/Build.java b/server/src/main/java/org/elasticsearch/Build.java index 89082389c5805..1ab2128a72f53 100644 --- a/server/src/main/java/org/elasticsearch/Build.java +++ b/server/src/main/java/org/elasticsearch/Build.java @@ -219,7 +219,7 @@ public static Build readBuild(StreamInput in) throws IOException { final String minWireVersion; final String minIndexVersion; final String displayString; - if (in.getTransportVersion().onOrAfter(TransportVersions.BUILD_QUALIFIER_SEPARATED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { version = in.readString(); qualifier = in.readOptionalString(); snapshot = in.readBoolean(); @@ -257,7 +257,7 @@ public static void writeBuild(Build build, StreamOutput out) throws IOException out.writeString(build.type().displayName()); out.writeString(build.hash()); out.writeString(build.date()); - if (out.getTransportVersion().onOrAfter(TransportVersions.BUILD_QUALIFIER_SEPARATED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeString(build.version()); out.writeOptionalString(build.qualifier()); out.writeBoolean(build.isSnapshot()); diff --git a/server/src/main/java/org/elasticsearch/ElasticsearchException.java b/server/src/main/java/org/elasticsearch/ElasticsearchException.java index 10a97930b85e5..bfda0c200faa5 100644 --- a/server/src/main/java/org/elasticsearch/ElasticsearchException.java +++ b/server/src/main/java/org/elasticsearch/ElasticsearchException.java @@ -1884,19 +1884,19 @@ private enum ElasticsearchExceptionHandle { TooManyScrollContextsException.class, TooManyScrollContextsException::new, 173, - TransportVersions.TOO_MANY_SCROLL_CONTEXTS_EXCEPTION_ADDED + TransportVersions.V_8_12_0 ), INVALID_BUCKET_PATH_EXCEPTION( AggregationExecutionException.InvalidPath.class, AggregationExecutionException.InvalidPath::new, 174, - TransportVersions.INVALID_BUCKET_PATH_EXCEPTION_INTRODUCED + TransportVersions.V_8_12_0 ), MISSED_INDICES_UPDATE_EXCEPTION( AutoscalingMissedIndicesUpdateException.class, AutoscalingMissedIndicesUpdateException::new, 175, - TransportVersions.MISSED_INDICES_UPDATE_EXCEPTION_ADDED + TransportVersions.V_8_12_0 ), SEARCH_TIMEOUT_EXCEPTION( SearchTimeoutException.class, diff --git a/server/src/main/java/org/elasticsearch/TransportVersions.java b/server/src/main/java/org/elasticsearch/TransportVersions.java index 27091e4ae3d32..5cac8edb4483e 100644 --- a/server/src/main/java/org/elasticsearch/TransportVersions.java +++ b/server/src/main/java/org/elasticsearch/TransportVersions.java @@ -96,54 +96,7 @@ static TransportVersion def(int id) { public static final TransportVersion V_8_9_X = def(8_500_020); public static final TransportVersion V_8_10_X = def(8_500_061); public static final TransportVersion V_8_11_X = def(8_512_00_1); - public static final TransportVersion PLUGIN_DESCRIPTOR_OPTIONAL_CLASSNAME = def(8_513_00_0); - public static final TransportVersion UNIVERSAL_PROFILING_LICENSE_ADDED = def(8_514_00_0); - public static final TransportVersion ELSER_SERVICE_MODEL_VERSION_ADDED = def(8_515_00_0); - public static final TransportVersion NODE_STATS_HTTP_ROUTE_STATS_ADDED = def(8_516_00_0); - public static final TransportVersion INCLUDE_SHARDS_STATS_ADDED = def(8_517_00_0); - public static final TransportVersion BUILD_QUALIFIER_SEPARATED = def(8_518_00_0); - public static final TransportVersion PIPELINES_IN_BULK_RESPONSE_ADDED = def(8_519_00_0); - public static final TransportVersion PLUGIN_DESCRIPTOR_STRING_VERSION = def(8_520_00_0); - public static final TransportVersion TOO_MANY_SCROLL_CONTEXTS_EXCEPTION_ADDED = def(8_521_00_0); - public static final TransportVersion UNCONTENDED_REGISTER_ANALYSIS_ADDED = def(8_522_00_0); - public static final TransportVersion TRANSFORM_GET_CHECKPOINT_TIMEOUT_ADDED = def(8_523_00_0); - public static final TransportVersion IP_ADDRESS_WRITEABLE = def(8_524_00_0); - public static final TransportVersion PRIMARY_TERM_ADDED = def(8_525_00_0); - public static final TransportVersion CLUSTER_FEATURES_ADDED = def(8_526_00_0); - public static final TransportVersion DSL_ERROR_STORE_INFORMATION_ENHANCED = def(8_527_00_0); - public static final TransportVersion INVALID_BUCKET_PATH_EXCEPTION_INTRODUCED = def(8_528_00_0); - public static final TransportVersion KNN_AS_QUERY_ADDED = def(8_529_00_0); - public static final TransportVersion UNDESIRED_SHARD_ALLOCATIONS_COUNT_ADDED = def(8_530_00_0); - public static final TransportVersion ML_INFERENCE_TASK_SETTINGS_OPTIONAL_ADDED = def(8_531_00_0); - public static final TransportVersion DEPRECATED_COMPONENT_TEMPLATES_ADDED = def(8_532_00_0); - public static final TransportVersion UPDATE_NON_DYNAMIC_SETTINGS_ADDED = def(8_533_00_0); - public static final TransportVersion REPO_ANALYSIS_REGISTER_OP_COUNT_ADDED = def(8_534_00_0); - public static final TransportVersion ML_TRAINED_MODEL_PREFIX_STRINGS_ADDED = def(8_535_00_0); - public static final TransportVersion COUNTED_KEYWORD_ADDED = def(8_536_00_0); - public static final TransportVersion SHAPE_VALUE_SERIALIZATION_ADDED = def(8_537_00_0); - public static final TransportVersion INFERENCE_MULTIPLE_INPUTS = def(8_538_00_0); - public static final TransportVersion ADDITIONAL_DESIRED_BALANCE_RECONCILIATION_STATS = def(8_539_00_0); - public static final TransportVersion ML_STATE_CHANGE_TIMESTAMPS = def(8_540_00_0); - public static final TransportVersion DATA_STREAM_FAILURE_STORE_ADDED = def(8_541_00_0); - public static final TransportVersion ML_INFERENCE_OPENAI_ADDED = def(8_542_00_0); - public static final TransportVersion SHUTDOWN_MIGRATION_STATUS_INCLUDE_COUNTS = def(8_543_00_0); - public static final TransportVersion TRANSFORM_GET_CHECKPOINT_QUERY_AND_CLUSTER_ADDED = def(8_544_00_0); - public static final TransportVersion GRANT_API_KEY_CLIENT_AUTHENTICATION_ADDED = def(8_545_00_0); - public static final TransportVersion PIT_WITH_INDEX_FILTER = def(8_546_00_0); - public static final TransportVersion NODE_INFO_VERSION_AS_STRING = def(8_547_00_0); - public static final TransportVersion GET_API_KEY_INVALIDATION_TIME_ADDED = def(8_548_00_0); - public static final TransportVersion ML_INFERENCE_GET_MULTIPLE_MODELS = def(8_549_00_0); - public static final TransportVersion INFERENCE_SERVICE_RESULTS_ADDED = def(8_550_00_0); - public static final TransportVersion ESQL_PROFILE = def(8_551_00_0); - public static final TransportVersion CLUSTER_STATS_RESCORER_USAGE_ADDED = def(8_552_00_0); - public static final TransportVersion ML_INFERENCE_HF_SERVICE_ADDED = def(8_553_00_0); - public static final TransportVersion INFERENCE_USAGE_ADDED = def(8_554_00_0); - public static final TransportVersion UPGRADE_TO_LUCENE_9_9 = def(8_555_00_0); - public static final TransportVersion HEALTH_INFO_ENRICHED_WITH_DSL_STATUS = def(8_556_00_0); - public static final TransportVersion SOURCE_IN_SINGLE_VALUE_QUERY_ADDED = def(8_557_00_0); - public static final TransportVersion MISSED_INDICES_UPDATE_EXCEPTION_ADDED = def(8_558_00_0); - public static final TransportVersion INFERENCE_SERVICE_EMBEDDING_SIZE_ADDED = def(8_559_00_0); - public static final TransportVersion ENRICH_ELASTICSEARCH_VERSION_REMOVED = def(8_560_00_0); + public static final TransportVersion V_8_12_0 = def(8_560_00_0); public static final TransportVersion DATE_HISTOGRAM_SUPPORT_DOWNSAMPLED_TZ_8_12_PATCH = def(8_560_00_1); public static final TransportVersion NODE_STATS_REQUEST_SIMPLIFIED = def(8_561_00_0); public static final TransportVersion TEXT_EXPANSION_TOKEN_PRUNING_CONFIG_ADDED = def(8_562_00_0); diff --git a/server/src/main/java/org/elasticsearch/action/admin/cluster/node/info/NodeInfo.java b/server/src/main/java/org/elasticsearch/action/admin/cluster/node/info/NodeInfo.java index fde58a8328091..97fbd2fa8c008 100644 --- a/server/src/main/java/org/elasticsearch/action/admin/cluster/node/info/NodeInfo.java +++ b/server/src/main/java/org/elasticsearch/action/admin/cluster/node/info/NodeInfo.java @@ -61,7 +61,7 @@ public class NodeInfo extends BaseNodeResponse { public NodeInfo(StreamInput in) throws IOException { super(in); - if (in.getTransportVersion().onOrAfter(TransportVersions.NODE_INFO_VERSION_AS_STRING)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { version = in.readString(); transportVersion = TransportVersion.readVersion(in); indexVersion = IndexVersion.readVersion(in); @@ -234,7 +234,7 @@ private void addInfoIfNonNull(Class clazz, @Override public void writeTo(StreamOutput out) throws IOException { super.writeTo(out); - if (out.getTransportVersion().onOrAfter(TransportVersions.NODE_INFO_VERSION_AS_STRING)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeString(version); } else { Version.writeVersion(Version.fromString(version), out); diff --git a/server/src/main/java/org/elasticsearch/action/admin/cluster/node/stats/NodesStatsRequestParameters.java b/server/src/main/java/org/elasticsearch/action/admin/cluster/node/stats/NodesStatsRequestParameters.java index 6c7ce472475cd..2948af59d17fd 100644 --- a/server/src/main/java/org/elasticsearch/action/admin/cluster/node/stats/NodesStatsRequestParameters.java +++ b/server/src/main/java/org/elasticsearch/action/admin/cluster/node/stats/NodesStatsRequestParameters.java @@ -34,7 +34,7 @@ public NodesStatsRequestParameters(StreamInput in) throws IOException { indices = new CommonStatsFlags(in); requestedMetrics.clear(); requestedMetrics.addAll(in.readStringCollectionAsList()); - if (in.getTransportVersion().onOrAfter(TransportVersions.INCLUDE_SHARDS_STATS_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { includeShardsStats = in.readBoolean(); } else { includeShardsStats = true; @@ -45,7 +45,7 @@ public NodesStatsRequestParameters(StreamInput in) throws IOException { public void writeTo(StreamOutput out) throws IOException { indices.writeTo(out); out.writeStringCollection(requestedMetrics); - if (out.getTransportVersion().onOrAfter(TransportVersions.INCLUDE_SHARDS_STATS_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeBoolean(includeShardsStats); } } diff --git a/server/src/main/java/org/elasticsearch/action/admin/cluster/stats/SearchUsageStats.java b/server/src/main/java/org/elasticsearch/action/admin/cluster/stats/SearchUsageStats.java index aa49e9f1ea01f..7903b3f3dffde 100644 --- a/server/src/main/java/org/elasticsearch/action/admin/cluster/stats/SearchUsageStats.java +++ b/server/src/main/java/org/elasticsearch/action/admin/cluster/stats/SearchUsageStats.java @@ -21,7 +21,7 @@ import java.util.Map; import java.util.Objects; -import static org.elasticsearch.TransportVersions.CLUSTER_STATS_RESCORER_USAGE_ADDED; +import static org.elasticsearch.TransportVersions.V_8_12_0; /** * Holds a snapshot of the search usage statistics. @@ -59,9 +59,7 @@ public SearchUsageStats(StreamInput in) throws IOException { this.queries = in.readMap(StreamInput::readLong); this.sections = in.readMap(StreamInput::readLong); this.totalSearchCount = in.readVLong(); - this.rescorers = in.getTransportVersion().onOrAfter(CLUSTER_STATS_RESCORER_USAGE_ADDED) - ? in.readMap(StreamInput::readLong) - : Map.of(); + this.rescorers = in.getTransportVersion().onOrAfter(V_8_12_0) ? in.readMap(StreamInput::readLong) : Map.of(); } @Override @@ -70,7 +68,7 @@ public void writeTo(StreamOutput out) throws IOException { out.writeMap(sections, StreamOutput::writeLong); out.writeVLong(totalSearchCount); - if (out.getTransportVersion().onOrAfter(CLUSTER_STATS_RESCORER_USAGE_ADDED)) { + if (out.getTransportVersion().onOrAfter(V_8_12_0)) { out.writeMap(rescorers, StreamOutput::writeLong); } } diff --git a/server/src/main/java/org/elasticsearch/action/admin/indices/refresh/UnpromotableShardRefreshRequest.java b/server/src/main/java/org/elasticsearch/action/admin/indices/refresh/UnpromotableShardRefreshRequest.java index 2e4492725dd8f..26d07b49ecef3 100644 --- a/server/src/main/java/org/elasticsearch/action/admin/indices/refresh/UnpromotableShardRefreshRequest.java +++ b/server/src/main/java/org/elasticsearch/action/admin/indices/refresh/UnpromotableShardRefreshRequest.java @@ -40,9 +40,7 @@ public UnpromotableShardRefreshRequest( public UnpromotableShardRefreshRequest(StreamInput in) throws IOException { super(in); segmentGeneration = in.readVLong(); - primaryTerm = in.getTransportVersion().onOrAfter(TransportVersions.PRIMARY_TERM_ADDED) - ? in.readVLong() - : Engine.UNKNOWN_PRIMARY_TERM; + primaryTerm = in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0) ? in.readVLong() : Engine.UNKNOWN_PRIMARY_TERM; } @Override @@ -58,7 +56,7 @@ public ActionRequestValidationException validate() { public void writeTo(StreamOutput out) throws IOException { super.writeTo(out); out.writeVLong(segmentGeneration); - if (out.getTransportVersion().onOrAfter(TransportVersions.PRIMARY_TERM_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeVLong(primaryTerm); } } diff --git a/server/src/main/java/org/elasticsearch/action/admin/indices/settings/put/UpdateSettingsRequest.java b/server/src/main/java/org/elasticsearch/action/admin/indices/settings/put/UpdateSettingsRequest.java index fba395748f476..b6f03f1477951 100644 --- a/server/src/main/java/org/elasticsearch/action/admin/indices/settings/put/UpdateSettingsRequest.java +++ b/server/src/main/java/org/elasticsearch/action/admin/indices/settings/put/UpdateSettingsRequest.java @@ -56,7 +56,7 @@ public UpdateSettingsRequest(StreamInput in) throws IOException { settings = readSettingsFromStream(in); preserveExisting = in.readBoolean(); origin = in.readString(); - if (in.getTransportVersion().onOrAfter(TransportVersions.UPDATE_NON_DYNAMIC_SETTINGS_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { reopen = in.readBoolean(); } } @@ -199,7 +199,7 @@ public void writeTo(StreamOutput out) throws IOException { settings.writeTo(out); out.writeBoolean(preserveExisting); out.writeString(origin); - if (out.getTransportVersion().onOrAfter(TransportVersions.UPDATE_NON_DYNAMIC_SETTINGS_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeBoolean(reopen); } } diff --git a/server/src/main/java/org/elasticsearch/action/datastreams/lifecycle/ExplainIndexDataStreamLifecycle.java b/server/src/main/java/org/elasticsearch/action/datastreams/lifecycle/ExplainIndexDataStreamLifecycle.java index ea78f43a54b21..640d8a9efe8ac 100644 --- a/server/src/main/java/org/elasticsearch/action/datastreams/lifecycle/ExplainIndexDataStreamLifecycle.java +++ b/server/src/main/java/org/elasticsearch/action/datastreams/lifecycle/ExplainIndexDataStreamLifecycle.java @@ -23,7 +23,7 @@ import java.util.Objects; import java.util.function.Supplier; -import static org.elasticsearch.TransportVersions.DSL_ERROR_STORE_INFORMATION_ENHANCED; +import static org.elasticsearch.TransportVersions.V_8_12_0; /** * Encapsulates the information that describes an index from its data stream lifecycle perspective. @@ -81,7 +81,7 @@ public ExplainIndexDataStreamLifecycle(StreamInput in) throws IOException { this.rolloverDate = in.readOptionalLong(); this.generationDateMillis = in.readOptionalLong(); this.lifecycle = in.readOptionalWriteable(DataStreamLifecycle::new); - if (in.getTransportVersion().onOrAfter(DSL_ERROR_STORE_INFORMATION_ENHANCED)) { + if (in.getTransportVersion().onOrAfter(V_8_12_0)) { this.error = in.readOptionalWriteable(ErrorEntry::new); } else { String bwcErrorMessage = in.readOptionalString(); @@ -151,7 +151,7 @@ public void writeTo(StreamOutput out) throws IOException { out.writeOptionalLong(rolloverDate); out.writeOptionalLong(generationDateMillis); out.writeOptionalWriteable(lifecycle); - if (out.getTransportVersion().onOrAfter(DSL_ERROR_STORE_INFORMATION_ENHANCED)) { + if (out.getTransportVersion().onOrAfter(V_8_12_0)) { out.writeOptionalWriteable(error); } else { String errorMessage = error != null ? error.error() : null; diff --git a/server/src/main/java/org/elasticsearch/action/get/TransportGetFromTranslogAction.java b/server/src/main/java/org/elasticsearch/action/get/TransportGetFromTranslogAction.java index cd47531f81599..f84e35e5303d1 100644 --- a/server/src/main/java/org/elasticsearch/action/get/TransportGetFromTranslogAction.java +++ b/server/src/main/java/org/elasticsearch/action/get/TransportGetFromTranslogAction.java @@ -154,16 +154,14 @@ public Response(StreamInput in) throws IOException { super(in); segmentGeneration = in.readZLong(); getResult = in.readOptionalWriteable(GetResult::new); - primaryTerm = in.getTransportVersion().onOrAfter(TransportVersions.PRIMARY_TERM_ADDED) - ? in.readVLong() - : Engine.UNKNOWN_PRIMARY_TERM; + primaryTerm = in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0) ? in.readVLong() : Engine.UNKNOWN_PRIMARY_TERM; } @Override public void writeTo(StreamOutput out) throws IOException { out.writeZLong(segmentGeneration); out.writeOptionalWriteable(getResult); - if (out.getTransportVersion().onOrAfter(TransportVersions.PRIMARY_TERM_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeVLong(primaryTerm); } } diff --git a/server/src/main/java/org/elasticsearch/action/get/TransportShardMultiGetFomTranslogAction.java b/server/src/main/java/org/elasticsearch/action/get/TransportShardMultiGetFomTranslogAction.java index 52504176eb7e1..ee354af979833 100644 --- a/server/src/main/java/org/elasticsearch/action/get/TransportShardMultiGetFomTranslogAction.java +++ b/server/src/main/java/org/elasticsearch/action/get/TransportShardMultiGetFomTranslogAction.java @@ -178,16 +178,14 @@ public Response(StreamInput in) throws IOException { super(in); segmentGeneration = in.readZLong(); multiGetShardResponse = new MultiGetShardResponse(in); - primaryTerm = in.getTransportVersion().onOrAfter(TransportVersions.PRIMARY_TERM_ADDED) - ? in.readVLong() - : Engine.UNKNOWN_PRIMARY_TERM; + primaryTerm = in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0) ? in.readVLong() : Engine.UNKNOWN_PRIMARY_TERM; } @Override public void writeTo(StreamOutput out) throws IOException { out.writeZLong(segmentGeneration); multiGetShardResponse.writeTo(out); - if (out.getTransportVersion().onOrAfter(TransportVersions.PRIMARY_TERM_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeVLong(primaryTerm); } } diff --git a/server/src/main/java/org/elasticsearch/action/index/IndexRequest.java b/server/src/main/java/org/elasticsearch/action/index/IndexRequest.java index bf2384f56576d..af8a76dc2e2d3 100644 --- a/server/src/main/java/org/elasticsearch/action/index/IndexRequest.java +++ b/server/src/main/java/org/elasticsearch/action/index/IndexRequest.java @@ -190,7 +190,7 @@ public IndexRequest(@Nullable ShardId shardId, StreamInput in) throws IOExceptio if (in.getTransportVersion().onOrAfter(PIPELINES_HAVE_RUN_FIELD_ADDED)) { pipelinesHaveRun = in.readBoolean(); } - if (in.getTransportVersion().onOrAfter(TransportVersions.PIPELINES_IN_BULK_RESPONSE_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { this.listExecutedPipelines = in.readBoolean(); if (listExecutedPipelines) { List possiblyImmutableExecutedPipelines = in.readOptionalCollectionAsList(StreamInput::readString); @@ -764,7 +764,7 @@ private void writeBody(StreamOutput out) throws IOException { if (out.getTransportVersion().onOrAfter(PIPELINES_HAVE_RUN_FIELD_ADDED)) { out.writeBoolean(pipelinesHaveRun); } - if (out.getTransportVersion().onOrAfter(TransportVersions.PIPELINES_IN_BULK_RESPONSE_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeBoolean(listExecutedPipelines); if (listExecutedPipelines) { out.writeOptionalCollection(executedPipelines, StreamOutput::writeString); diff --git a/server/src/main/java/org/elasticsearch/action/index/IndexResponse.java b/server/src/main/java/org/elasticsearch/action/index/IndexResponse.java index a9c0c8ef42380..e3598c33d5951 100644 --- a/server/src/main/java/org/elasticsearch/action/index/IndexResponse.java +++ b/server/src/main/java/org/elasticsearch/action/index/IndexResponse.java @@ -41,7 +41,7 @@ public class IndexResponse extends DocWriteResponse { public IndexResponse(ShardId shardId, StreamInput in) throws IOException { super(shardId, in); - if (in.getTransportVersion().onOrAfter(TransportVersions.PIPELINES_IN_BULK_RESPONSE_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { executedPipelines = in.readOptionalCollectionAsList(StreamInput::readString); } else { executedPipelines = null; @@ -50,7 +50,7 @@ public IndexResponse(ShardId shardId, StreamInput in) throws IOException { public IndexResponse(StreamInput in) throws IOException { super(in); - if (in.getTransportVersion().onOrAfter(TransportVersions.PIPELINES_IN_BULK_RESPONSE_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { executedPipelines = in.readOptionalCollectionAsList(StreamInput::readString); } else { executedPipelines = null; @@ -89,7 +89,7 @@ private IndexResponse( @Override public void writeTo(StreamOutput out) throws IOException { super.writeTo(out); - if (out.getTransportVersion().onOrAfter(TransportVersions.PIPELINES_IN_BULK_RESPONSE_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeOptionalCollection(executedPipelines, StreamOutput::writeString); } } @@ -97,7 +97,7 @@ public void writeTo(StreamOutput out) throws IOException { @Override public void writeThin(StreamOutput out) throws IOException { super.writeThin(out); - if (out.getTransportVersion().onOrAfter(TransportVersions.PIPELINES_IN_BULK_RESPONSE_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeOptionalCollection(executedPipelines, StreamOutput::writeString); } } diff --git a/server/src/main/java/org/elasticsearch/action/search/OpenPointInTimeRequest.java b/server/src/main/java/org/elasticsearch/action/search/OpenPointInTimeRequest.java index 874437311d086..a1cd4df25a25c 100644 --- a/server/src/main/java/org/elasticsearch/action/search/OpenPointInTimeRequest.java +++ b/server/src/main/java/org/elasticsearch/action/search/OpenPointInTimeRequest.java @@ -57,7 +57,7 @@ public OpenPointInTimeRequest(StreamInput in) throws IOException { if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_9_X)) { this.maxConcurrentShardRequests = in.readVInt(); } - if (in.getTransportVersion().onOrAfter(TransportVersions.PIT_WITH_INDEX_FILTER)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { this.indexFilter = in.readOptionalNamedWriteable(QueryBuilder.class); } } @@ -73,7 +73,7 @@ public void writeTo(StreamOutput out) throws IOException { if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_9_X)) { out.writeVInt(maxConcurrentShardRequests); } - if (out.getTransportVersion().onOrAfter(TransportVersions.PIT_WITH_INDEX_FILTER)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeOptionalWriteable(indexFilter); } } diff --git a/server/src/main/java/org/elasticsearch/cluster/ClusterState.java b/server/src/main/java/org/elasticsearch/cluster/ClusterState.java index 6deac76b171d6..f1fa1e4d1cb72 100644 --- a/server/src/main/java/org/elasticsearch/cluster/ClusterState.java +++ b/server/src/main/java/org/elasticsearch/cluster/ClusterState.java @@ -1010,7 +1010,7 @@ public static ClusterState readFrom(StreamInput in, DiscoveryNode localNode) thr .values() .forEach(n -> builder.putCompatibilityVersions(n.getId(), inferTransportVersion(n), Map.of())); } - if (in.getTransportVersion().onOrAfter(TransportVersions.CLUSTER_FEATURES_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { builder.nodeFeatures(ClusterFeatures.readFrom(in)); } builder.blocks = ClusterBlocks.readFrom(in); @@ -1056,7 +1056,7 @@ public void writeTo(StreamOutput out) throws IOException { if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_8_0)) { out.writeMap(compatibilityVersions, (streamOutput, versions) -> versions.writeTo(streamOutput)); } - if (out.getTransportVersion().onOrAfter(TransportVersions.CLUSTER_FEATURES_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { clusterFeatures.writeTo(out); } blocks.writeTo(out); @@ -1125,7 +1125,7 @@ private static class ClusterStateDiff implements Diff { } else { versions = null; // infer at application time } - if (in.getTransportVersion().onOrAfter(TransportVersions.CLUSTER_FEATURES_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { features = ClusterFeatures.readDiffFrom(in); } else { features = null; // fill in when nodes re-register with a master that understands features @@ -1149,7 +1149,7 @@ public void writeTo(StreamOutput out) throws IOException { if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_8_0)) { out.writeOptionalWriteable(versions); } - if (out.getTransportVersion().onOrAfter(TransportVersions.CLUSTER_FEATURES_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { features.writeTo(out); } metadata.writeTo(out); diff --git a/server/src/main/java/org/elasticsearch/cluster/coordination/JoinRequest.java b/server/src/main/java/org/elasticsearch/cluster/coordination/JoinRequest.java index a6a2f454694ae..1817497d0912c 100644 --- a/server/src/main/java/org/elasticsearch/cluster/coordination/JoinRequest.java +++ b/server/src/main/java/org/elasticsearch/cluster/coordination/JoinRequest.java @@ -81,7 +81,7 @@ public JoinRequest(StreamInput in) throws IOException { Map.of() ); } - if (in.getTransportVersion().onOrAfter(TransportVersions.CLUSTER_FEATURES_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { features = in.readCollectionAsSet(StreamInput::readString); } else { features = Set.of(); @@ -97,7 +97,7 @@ public void writeTo(StreamOutput out) throws IOException { if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_8_0)) { compatibilityVersions.writeTo(out); } - if (out.getTransportVersion().onOrAfter(TransportVersions.CLUSTER_FEATURES_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeCollection(features, StreamOutput::writeString); } out.writeLong(minimumTerm); diff --git a/server/src/main/java/org/elasticsearch/cluster/metadata/ComponentTemplate.java b/server/src/main/java/org/elasticsearch/cluster/metadata/ComponentTemplate.java index 8b5548c9ea8ef..d3d758e110ff3 100644 --- a/server/src/main/java/org/elasticsearch/cluster/metadata/ComponentTemplate.java +++ b/server/src/main/java/org/elasticsearch/cluster/metadata/ComponentTemplate.java @@ -92,7 +92,7 @@ public ComponentTemplate(StreamInput in) throws IOException { } else { this.metadata = null; } - if (in.getTransportVersion().onOrAfter(TransportVersions.DEPRECATED_COMPONENT_TEMPLATES_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { this.deprecated = in.readOptionalBoolean(); } else { deprecated = null; @@ -131,7 +131,7 @@ public void writeTo(StreamOutput out) throws IOException { out.writeBoolean(true); out.writeGenericMap(this.metadata); } - if (out.getTransportVersion().onOrAfter(TransportVersions.DEPRECATED_COMPONENT_TEMPLATES_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeOptionalBoolean(this.deprecated); } } diff --git a/server/src/main/java/org/elasticsearch/cluster/metadata/ComposableIndexTemplate.java b/server/src/main/java/org/elasticsearch/cluster/metadata/ComposableIndexTemplate.java index 2cc09beffa28a..dfd4431eb073c 100644 --- a/server/src/main/java/org/elasticsearch/cluster/metadata/ComposableIndexTemplate.java +++ b/server/src/main/java/org/elasticsearch/cluster/metadata/ComposableIndexTemplate.java @@ -153,7 +153,7 @@ public ComposableIndexTemplate(StreamInput in) throws IOException { } else { this.ignoreMissingComponentTemplates = null; } - if (in.getTransportVersion().onOrAfter(TransportVersions.DEPRECATED_COMPONENT_TEMPLATES_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { this.deprecated = in.readOptionalBoolean(); } else { this.deprecated = null; @@ -252,7 +252,7 @@ public void writeTo(StreamOutput out) throws IOException { if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_7_0)) { out.writeOptionalStringCollection(ignoreMissingComponentTemplates); } - if (out.getTransportVersion().onOrAfter(TransportVersions.DEPRECATED_COMPONENT_TEMPLATES_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeOptionalBoolean(deprecated); } } diff --git a/server/src/main/java/org/elasticsearch/cluster/metadata/DataStream.java b/server/src/main/java/org/elasticsearch/cluster/metadata/DataStream.java index ff31c6fe950d7..8cb4b39efac78 100644 --- a/server/src/main/java/org/elasticsearch/cluster/metadata/DataStream.java +++ b/server/src/main/java/org/elasticsearch/cluster/metadata/DataStream.java @@ -69,7 +69,7 @@ public final class DataStream implements SimpleDiffable, ToXContentObject, IndexAbstraction { public static final FeatureFlag FAILURE_STORE_FEATURE_FLAG = new FeatureFlag("failure_store"); - public static final TransportVersion ADDED_FAILURE_STORE_TRANSPORT_VERSION = TransportVersions.DATA_STREAM_FAILURE_STORE_ADDED; + public static final TransportVersion ADDED_FAILURE_STORE_TRANSPORT_VERSION = TransportVersions.V_8_12_0; public static boolean isFailureStoreEnabled() { return FAILURE_STORE_FEATURE_FLAG.isEnabled(); diff --git a/server/src/main/java/org/elasticsearch/cluster/metadata/ShutdownShardMigrationStatus.java b/server/src/main/java/org/elasticsearch/cluster/metadata/ShutdownShardMigrationStatus.java index 15fab193dad57..91411f7b86eca 100644 --- a/server/src/main/java/org/elasticsearch/cluster/metadata/ShutdownShardMigrationStatus.java +++ b/server/src/main/java/org/elasticsearch/cluster/metadata/ShutdownShardMigrationStatus.java @@ -109,7 +109,7 @@ private ShutdownShardMigrationStatus( public ShutdownShardMigrationStatus(StreamInput in) throws IOException { this.status = in.readEnum(SingleNodeShutdownMetadata.Status.class); - if (in.getTransportVersion().onOrAfter(TransportVersions.SHUTDOWN_MIGRATION_STATUS_INCLUDE_COUNTS)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { this.startedShards = in.readZLong(); this.relocatingShards = in.readZLong(); this.initializingShards = in.readZLong(); @@ -169,7 +169,7 @@ private XContentBuilder buildHeader(XContentBuilder builder) throws IOException @Override public void writeTo(StreamOutput out) throws IOException { out.writeEnum(status); - if (out.getTransportVersion().onOrAfter(TransportVersions.SHUTDOWN_MIGRATION_STATUS_INCLUDE_COUNTS)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeZLong(startedShards); out.writeZLong(relocatingShards); out.writeZLong(initializingShards); diff --git a/server/src/main/java/org/elasticsearch/cluster/routing/allocation/allocator/ClusterBalanceStats.java b/server/src/main/java/org/elasticsearch/cluster/routing/allocation/allocator/ClusterBalanceStats.java index 5df5de43cffdd..1f3444360eb85 100644 --- a/server/src/main/java/org/elasticsearch/cluster/routing/allocation/allocator/ClusterBalanceStats.java +++ b/server/src/main/java/org/elasticsearch/cluster/routing/allocation/allocator/ClusterBalanceStats.java @@ -75,8 +75,8 @@ public static ClusterBalanceStats createFrom( public static ClusterBalanceStats readFrom(StreamInput in) throws IOException { return new ClusterBalanceStats( - in.getTransportVersion().onOrAfter(TransportVersions.UNDESIRED_SHARD_ALLOCATIONS_COUNT_ADDED) ? in.readVInt() : -1, - in.getTransportVersion().onOrAfter(TransportVersions.UNDESIRED_SHARD_ALLOCATIONS_COUNT_ADDED) ? in.readVInt() : -1, + in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0) ? in.readVInt() : -1, + in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0) ? in.readVInt() : -1, in.readImmutableMap(TierBalanceStats::readFrom), in.readImmutableMap(NodeBalanceStats::readFrom) ); @@ -84,10 +84,8 @@ public static ClusterBalanceStats readFrom(StreamInput in) throws IOException { @Override public void writeTo(StreamOutput out) throws IOException { - if (out.getTransportVersion().onOrAfter(TransportVersions.UNDESIRED_SHARD_ALLOCATIONS_COUNT_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeVInt(shards); - } - if (out.getTransportVersion().onOrAfter(TransportVersions.UNDESIRED_SHARD_ALLOCATIONS_COUNT_ADDED)) { out.writeVInt(undesiredShardAllocations); } out.writeMap(tiers, StreamOutput::writeWriteable); @@ -125,7 +123,7 @@ private static TierBalanceStats createFrom(List nodes) { public static TierBalanceStats readFrom(StreamInput in) throws IOException { return new TierBalanceStats( MetricStats.readFrom(in), - in.getTransportVersion().onOrAfter(TransportVersions.UNDESIRED_SHARD_ALLOCATIONS_COUNT_ADDED) + in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0) ? MetricStats.readFrom(in) : new MetricStats(0.0, 0.0, 0.0, 0.0, 0.0), MetricStats.readFrom(in), @@ -137,7 +135,7 @@ public static TierBalanceStats readFrom(StreamInput in) throws IOException { @Override public void writeTo(StreamOutput out) throws IOException { shardCount.writeTo(out); - if (out.getTransportVersion().onOrAfter(TransportVersions.UNDESIRED_SHARD_ALLOCATIONS_COUNT_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { undesiredShardAllocations.writeTo(out); } forecastWriteLoad.writeTo(out); @@ -268,7 +266,7 @@ public static NodeBalanceStats readFrom(StreamInput in) throws IOException { in.getTransportVersion().onOrAfter(TransportVersions.V_8_8_0) ? in.readString() : UNKNOWN_NODE_ID, in.getTransportVersion().onOrAfter(TransportVersions.V_8_8_0) ? in.readStringCollectionAsList() : List.of(), in.readInt(), - in.getTransportVersion().onOrAfter(TransportVersions.UNDESIRED_SHARD_ALLOCATIONS_COUNT_ADDED) ? in.readVInt() : -1, + in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0) ? in.readVInt() : -1, in.readDouble(), in.readLong(), in.readLong() @@ -279,12 +277,10 @@ public static NodeBalanceStats readFrom(StreamInput in) throws IOException { public void writeTo(StreamOutput out) throws IOException { if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_8_0)) { out.writeString(nodeId); - } - if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_8_0)) { out.writeStringCollection(roles); } out.writeInt(shards); - if (out.getTransportVersion().onOrAfter(TransportVersions.UNDESIRED_SHARD_ALLOCATIONS_COUNT_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeVInt(undesiredShardAllocations); } out.writeDouble(forecastWriteLoad); diff --git a/server/src/main/java/org/elasticsearch/cluster/routing/allocation/allocator/DesiredBalanceStats.java b/server/src/main/java/org/elasticsearch/cluster/routing/allocation/allocator/DesiredBalanceStats.java index 8a95b947735f1..9ffa2b434754a 100644 --- a/server/src/main/java/org/elasticsearch/cluster/routing/allocation/allocator/DesiredBalanceStats.java +++ b/server/src/main/java/org/elasticsearch/cluster/routing/allocation/allocator/DesiredBalanceStats.java @@ -19,7 +19,7 @@ import java.io.IOException; -import static org.elasticsearch.TransportVersions.ADDITIONAL_DESIRED_BALANCE_RECONCILIATION_STATS; +import static org.elasticsearch.TransportVersions.V_8_12_0; public record DesiredBalanceStats( long lastConvergedIndex, @@ -56,9 +56,9 @@ public static DesiredBalanceStats readFrom(StreamInput in) throws IOException { in.getTransportVersion().onOrAfter(COMPUTED_SHARD_MOVEMENTS_VERSION) ? in.readVLong() : -1, in.readVLong(), in.readVLong(), - in.getTransportVersion().onOrAfter(ADDITIONAL_DESIRED_BALANCE_RECONCILIATION_STATS) ? in.readVLong() : -1, - in.getTransportVersion().onOrAfter(ADDITIONAL_DESIRED_BALANCE_RECONCILIATION_STATS) ? in.readVLong() : -1, - in.getTransportVersion().onOrAfter(ADDITIONAL_DESIRED_BALANCE_RECONCILIATION_STATS) ? in.readVLong() : -1 + in.getTransportVersion().onOrAfter(V_8_12_0) ? in.readVLong() : -1, + in.getTransportVersion().onOrAfter(V_8_12_0) ? in.readVLong() : -1, + in.getTransportVersion().onOrAfter(V_8_12_0) ? in.readVLong() : -1 ); } @@ -75,7 +75,7 @@ public void writeTo(StreamOutput out) throws IOException { } out.writeVLong(cumulativeComputationTime); out.writeVLong(cumulativeReconciliationTime); - if (out.getTransportVersion().onOrAfter(ADDITIONAL_DESIRED_BALANCE_RECONCILIATION_STATS)) { + if (out.getTransportVersion().onOrAfter(V_8_12_0)) { out.writeVLong(unassignedShards); out.writeVLong(totalAllocations); out.writeVLong(undesiredAllocations); diff --git a/server/src/main/java/org/elasticsearch/health/node/HealthInfo.java b/server/src/main/java/org/elasticsearch/health/node/HealthInfo.java index 97087c05e8de8..697c5eff939f9 100644 --- a/server/src/main/java/org/elasticsearch/health/node/HealthInfo.java +++ b/server/src/main/java/org/elasticsearch/health/node/HealthInfo.java @@ -36,7 +36,7 @@ public record HealthInfo( public HealthInfo(StreamInput input) throws IOException { this( input.readMap(DiskHealthInfo::new), - input.getTransportVersion().onOrAfter(TransportVersions.HEALTH_INFO_ENRICHED_WITH_DSL_STATUS) + input.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0) ? input.readOptionalWriteable(DataStreamLifecycleHealthInfo::new) : null, input.getTransportVersion().onOrAfter(TransportVersions.HEALTH_INFO_ENRICHED_WITH_REPOS) @@ -48,7 +48,7 @@ public HealthInfo(StreamInput input) throws IOException { @Override public void writeTo(StreamOutput output) throws IOException { output.writeMap(diskInfoByNode, StreamOutput::writeWriteable); - if (output.getTransportVersion().onOrAfter(TransportVersions.HEALTH_INFO_ENRICHED_WITH_DSL_STATUS)) { + if (output.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { output.writeOptionalWriteable(dslHealthInfo); } if (output.getTransportVersion().onOrAfter(TransportVersions.HEALTH_INFO_ENRICHED_WITH_REPOS)) { diff --git a/server/src/main/java/org/elasticsearch/health/node/UpdateHealthInfoCacheAction.java b/server/src/main/java/org/elasticsearch/health/node/UpdateHealthInfoCacheAction.java index bbbe84630f20a..49be1f6cce3ad 100644 --- a/server/src/main/java/org/elasticsearch/health/node/UpdateHealthInfoCacheAction.java +++ b/server/src/main/java/org/elasticsearch/health/node/UpdateHealthInfoCacheAction.java @@ -63,7 +63,7 @@ public Request(String nodeId, DataStreamLifecycleHealthInfo dslHealthInfo) { public Request(StreamInput in) throws IOException { super(in); this.nodeId = in.readString(); - if (in.getTransportVersion().onOrAfter(TransportVersions.HEALTH_INFO_ENRICHED_WITH_DSL_STATUS)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { this.diskHealthInfo = in.readOptionalWriteable(DiskHealthInfo::new); this.dslHealthInfo = in.readOptionalWriteable(DataStreamLifecycleHealthInfo::new); this.repositoriesHealthInfo = in.getTransportVersion().onOrAfter(TransportVersions.HEALTH_INFO_ENRICHED_WITH_REPOS) @@ -105,7 +105,7 @@ public ActionRequestValidationException validate() { public void writeTo(StreamOutput out) throws IOException { super.writeTo(out); out.writeString(nodeId); - if (out.getTransportVersion().onOrAfter(TransportVersions.HEALTH_INFO_ENRICHED_WITH_DSL_STATUS)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeOptionalWriteable(diskHealthInfo); out.writeOptionalWriteable(dslHealthInfo); if (out.getTransportVersion().onOrAfter(TransportVersions.HEALTH_INFO_ENRICHED_WITH_REPOS)) { diff --git a/server/src/main/java/org/elasticsearch/http/HttpStats.java b/server/src/main/java/org/elasticsearch/http/HttpStats.java index 3383ab6446bf3..a78e79b2fc366 100644 --- a/server/src/main/java/org/elasticsearch/http/HttpStats.java +++ b/server/src/main/java/org/elasticsearch/http/HttpStats.java @@ -24,7 +24,7 @@ import java.util.stream.Collectors; import java.util.stream.Stream; -import static org.elasticsearch.TransportVersions.NODE_STATS_HTTP_ROUTE_STATS_ADDED; +import static org.elasticsearch.TransportVersions.V_8_12_0; public record HttpStats(long serverOpen, long totalOpen, List clientStats, Map httpRouteStats) implements @@ -42,7 +42,7 @@ public HttpStats(StreamInput in) throws IOException { in.readVLong(), in.readVLong(), in.readCollectionAsList(ClientStats::new), - in.getTransportVersion().onOrAfter(NODE_STATS_HTTP_ROUTE_STATS_ADDED) ? in.readMap(HttpRouteStats::new) : Map.of() + in.getTransportVersion().onOrAfter(V_8_12_0) ? in.readMap(HttpRouteStats::new) : Map.of() ); } @@ -51,7 +51,7 @@ public void writeTo(StreamOutput out) throws IOException { out.writeVLong(serverOpen); out.writeVLong(totalOpen); out.writeCollection(clientStats); - if (out.getTransportVersion().onOrAfter(NODE_STATS_HTTP_ROUTE_STATS_ADDED)) { + if (out.getTransportVersion().onOrAfter(V_8_12_0)) { out.writeMap(httpRouteStats, StreamOutput::writeWriteable); } } diff --git a/server/src/main/java/org/elasticsearch/inference/EmptyTaskSettings.java b/server/src/main/java/org/elasticsearch/inference/EmptyTaskSettings.java index 24bfef4ec3137..aa85f3663efdf 100644 --- a/server/src/main/java/org/elasticsearch/inference/EmptyTaskSettings.java +++ b/server/src/main/java/org/elasticsearch/inference/EmptyTaskSettings.java @@ -42,7 +42,7 @@ public String getWriteableName() { @Override public TransportVersion getMinimalSupportedVersion() { - return TransportVersions.ML_INFERENCE_TASK_SETTINGS_OPTIONAL_ADDED; + return TransportVersions.V_8_12_0; } @Override diff --git a/server/src/main/java/org/elasticsearch/inference/InferenceServiceResults.java b/server/src/main/java/org/elasticsearch/inference/InferenceServiceResults.java index ab5b74faa6530..62166115820f5 100644 --- a/server/src/main/java/org/elasticsearch/inference/InferenceServiceResults.java +++ b/server/src/main/java/org/elasticsearch/inference/InferenceServiceResults.java @@ -29,7 +29,7 @@ public interface InferenceServiceResults extends NamedWriteable, ToXContentFragm /** * Transform the result to match the format required for versions prior to - * {@link org.elasticsearch.TransportVersions#INFERENCE_SERVICE_RESULTS_ADDED} + * {@link org.elasticsearch.TransportVersions#V_8_12_0} */ List transformToLegacyFormat(); diff --git a/server/src/main/java/org/elasticsearch/plugins/PluginDescriptor.java b/server/src/main/java/org/elasticsearch/plugins/PluginDescriptor.java index e0ee229fe1f98..db4b20594534b 100644 --- a/server/src/main/java/org/elasticsearch/plugins/PluginDescriptor.java +++ b/server/src/main/java/org/elasticsearch/plugins/PluginDescriptor.java @@ -120,13 +120,13 @@ public PluginDescriptor(final StreamInput in) throws IOException { this.name = in.readString(); this.description = in.readString(); this.version = in.readString(); - if (in.getTransportVersion().before(TransportVersions.PLUGIN_DESCRIPTOR_STRING_VERSION)) { + if (in.getTransportVersion().before(TransportVersions.V_8_12_0)) { elasticsearchVersion = Version.readVersion(in).toString(); } else { elasticsearchVersion = in.readString(); } javaVersion = in.readString(); - if (in.getTransportVersion().onOrAfter(TransportVersions.PLUGIN_DESCRIPTOR_OPTIONAL_CLASSNAME)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { this.classname = in.readOptionalString(); } else { this.classname = in.readString(); @@ -165,13 +165,13 @@ public void writeTo(final StreamOutput out) throws IOException { out.writeString(name); out.writeString(description); out.writeString(version); - if (out.getTransportVersion().before(TransportVersions.PLUGIN_DESCRIPTOR_STRING_VERSION)) { + if (out.getTransportVersion().before(TransportVersions.V_8_12_0)) { Version.writeVersion(Version.fromString(elasticsearchVersion), out); } else { out.writeString(elasticsearchVersion); } out.writeString(javaVersion); - if (out.getTransportVersion().onOrAfter(TransportVersions.PLUGIN_DESCRIPTOR_OPTIONAL_CLASSNAME)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeOptionalString(classname); } else { out.writeString(classname); diff --git a/server/src/main/java/org/elasticsearch/script/field/IPAddress.java b/server/src/main/java/org/elasticsearch/script/field/IPAddress.java index ed49928d6afa6..2b15fc321fdb4 100644 --- a/server/src/main/java/org/elasticsearch/script/field/IPAddress.java +++ b/server/src/main/java/org/elasticsearch/script/field/IPAddress.java @@ -70,6 +70,6 @@ public String getWriteableName() { @Override public TransportVersion getMinimalSupportedVersion() { - return TransportVersions.IP_ADDRESS_WRITEABLE; + return TransportVersions.V_8_12_0; } } diff --git a/server/src/main/java/org/elasticsearch/search/aggregations/bucket/countedterms/CountedTermsAggregationBuilder.java b/server/src/main/java/org/elasticsearch/search/aggregations/bucket/countedterms/CountedTermsAggregationBuilder.java index 4f71c964ebaf9..f2de187895e84 100644 --- a/server/src/main/java/org/elasticsearch/search/aggregations/bucket/countedterms/CountedTermsAggregationBuilder.java +++ b/server/src/main/java/org/elasticsearch/search/aggregations/bucket/countedterms/CountedTermsAggregationBuilder.java @@ -89,7 +89,7 @@ public CountedTermsAggregationBuilder size(int size) { @Override public TransportVersion getMinimalSupportedVersion() { - return TransportVersions.COUNTED_KEYWORD_ADDED; + return TransportVersions.V_8_12_0; } @Override diff --git a/server/src/main/java/org/elasticsearch/search/profile/query/QueryProfileShardResult.java b/server/src/main/java/org/elasticsearch/search/profile/query/QueryProfileShardResult.java index 1b799983dd0a4..e72ef2d9b3ece 100644 --- a/server/src/main/java/org/elasticsearch/search/profile/query/QueryProfileShardResult.java +++ b/server/src/main/java/org/elasticsearch/search/profile/query/QueryProfileShardResult.java @@ -72,9 +72,7 @@ public QueryProfileShardResult(StreamInput in) throws IOException { profileCollector = new CollectorResult(in); rewriteTime = in.readLong(); - vectorOperationsCount = (in.getTransportVersion().onOrAfter(TransportVersions.UPGRADE_TO_LUCENE_9_9)) - ? in.readOptionalLong() - : null; + vectorOperationsCount = (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) ? in.readOptionalLong() : null; } @Override @@ -85,7 +83,7 @@ public void writeTo(StreamOutput out) throws IOException { } profileCollector.writeTo(out); out.writeLong(rewriteTime); - if (out.getTransportVersion().onOrAfter(TransportVersions.UPGRADE_TO_LUCENE_9_9)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeOptionalLong(vectorOperationsCount); } } diff --git a/server/src/main/java/org/elasticsearch/search/vectors/KnnVectorQueryBuilder.java b/server/src/main/java/org/elasticsearch/search/vectors/KnnVectorQueryBuilder.java index 1dc1f97862035..96a16013ab874 100644 --- a/server/src/main/java/org/elasticsearch/search/vectors/KnnVectorQueryBuilder.java +++ b/server/src/main/java/org/elasticsearch/search/vectors/KnnVectorQueryBuilder.java @@ -120,8 +120,7 @@ public KnnVectorQueryBuilder(StreamInput in) throws IOException { } else { this.numCands = in.readVInt(); } - if (in.getTransportVersion().before(TransportVersions.V_8_7_0) - || in.getTransportVersion().onOrAfter(TransportVersions.KNN_AS_QUERY_ADDED)) { + if (in.getTransportVersion().before(TransportVersions.V_8_7_0) || in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { this.queryVector = in.readFloatArray(); } else { in.readBoolean(); @@ -191,7 +190,7 @@ protected void doWriteTo(StreamOutput out) throws IOException { } } if (out.getTransportVersion().before(TransportVersions.V_8_7_0) - || out.getTransportVersion().onOrAfter(TransportVersions.KNN_AS_QUERY_ADDED)) { + || out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeFloatArray(queryVector); } else { out.writeBoolean(true); diff --git a/server/src/test/java/org/elasticsearch/BuildTests.java b/server/src/test/java/org/elasticsearch/BuildTests.java index d4ef0fc881b1b..dba7a8c3a732b 100644 --- a/server/src/test/java/org/elasticsearch/BuildTests.java +++ b/server/src/test/java/org/elasticsearch/BuildTests.java @@ -91,7 +91,7 @@ public void testStrictTypeParsing() { public void testSerializationQualifierBwc() throws IOException { var randomBuild = new WriteableBuild(randomBuild()); - var serializationVersion = TransportVersionUtils.getPreviousVersion(TransportVersions.BUILD_QUALIFIER_SEPARATED); + var serializationVersion = TransportVersionUtils.getPreviousVersion(TransportVersions.V_8_12_0); var roundtrip = copyWriteable(randomBuild, writableRegistry(), WriteableBuild::new, serializationVersion); assertThat(roundtrip.build.version(), equalTo(randomBuild.build.version())); assertThat(roundtrip.build.qualifier(), equalTo(randomBuild.build.qualifier())); diff --git a/server/src/test/java/org/elasticsearch/search/vectors/AbstractKnnVectorQueryBuilderTestCase.java b/server/src/test/java/org/elasticsearch/search/vectors/AbstractKnnVectorQueryBuilderTestCase.java index e52a638f566a1..ad9c95b5b80c7 100644 --- a/server/src/test/java/org/elasticsearch/search/vectors/AbstractKnnVectorQueryBuilderTestCase.java +++ b/server/src/test/java/org/elasticsearch/search/vectors/AbstractKnnVectorQueryBuilderTestCase.java @@ -220,7 +220,7 @@ public void testBWCVersionSerializationQuery() throws IOException { TransportVersion differentQueryVersion = TransportVersionUtils.randomVersionBetween( random(), TransportVersions.V_8_2_0, - TransportVersions.KNN_AS_QUERY_ADDED + TransportVersions.V_8_12_0 ); Float similarity = differentQueryVersion.before(TransportVersions.V_8_8_0) ? null : query.getVectorSimilarity(); KnnVectorQueryBuilder queryOlderVersion = new KnnVectorQueryBuilder( diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/application/ProfilingUsage.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/application/ProfilingUsage.java index f566628c47c43..a487bbb4e27df 100644 --- a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/application/ProfilingUsage.java +++ b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/application/ProfilingUsage.java @@ -26,6 +26,6 @@ public ProfilingUsage(boolean available, boolean enabled) { @Override public TransportVersion getMinimalSupportedVersion() { - return TransportVersions.UNIVERSAL_PROFILING_LICENSE_ADDED; + return TransportVersions.V_8_12_0; } } diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/enrich/EnrichPolicy.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/enrich/EnrichPolicy.java index 74b274f2fd387..916bd3c62a598 100644 --- a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/enrich/EnrichPolicy.java +++ b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/enrich/EnrichPolicy.java @@ -117,7 +117,7 @@ public EnrichPolicy(StreamInput in) throws IOException { this.indices = in.readStringCollectionAsList(); this.matchField = in.readString(); this.enrichFields = in.readStringCollectionAsList(); - if (in.getTransportVersion().before(TransportVersions.ENRICH_ELASTICSEARCH_VERSION_REMOVED)) { + if (in.getTransportVersion().before(TransportVersions.V_8_12_0)) { // consume the passed-in meaningless version that old elasticsearch clusters will send Version.readVersion(in); } @@ -208,7 +208,7 @@ public void writeTo(StreamOutput out) throws IOException { out.writeStringCollection(indices); out.writeString(matchField); out.writeStringCollection(enrichFields); - if (out.getTransportVersion().before(TransportVersions.ENRICH_ELASTICSEARCH_VERSION_REMOVED)) { + if (out.getTransportVersion().before(TransportVersions.V_8_12_0)) { // emit the current version of elasticsearch for bwc serialization reasons Version.writeVersion(Version.CURRENT, out); } diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ilm/LifecyclePolicy.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ilm/LifecyclePolicy.java index b8bb0233b2c91..ee42eb8b3fce3 100644 --- a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ilm/LifecyclePolicy.java +++ b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ilm/LifecyclePolicy.java @@ -110,7 +110,7 @@ public LifecyclePolicy(StreamInput in) throws IOException { name = in.readString(); phases = in.readImmutableMap(Phase::new); this.metadata = in.readGenericMap(); - if (in.getTransportVersion().onOrAfter(TransportVersions.DEPRECATED_COMPONENT_TEMPLATES_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { this.deprecated = in.readOptionalBoolean(); } else { this.deprecated = null; @@ -156,7 +156,7 @@ public void writeTo(StreamOutput out) throws IOException { out.writeString(name); out.writeMap(phases, StreamOutput::writeWriteable); out.writeGenericMap(this.metadata); - if (out.getTransportVersion().onOrAfter(TransportVersions.DEPRECATED_COMPONENT_TEMPLATES_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeOptionalBoolean(deprecated); } } diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/inference/InferenceFeatureSetUsage.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/inference/InferenceFeatureSetUsage.java index 08a9329e20561..8464821275aa8 100644 --- a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/inference/InferenceFeatureSetUsage.java +++ b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/inference/InferenceFeatureSetUsage.java @@ -111,6 +111,6 @@ public void writeTo(StreamOutput out) throws IOException { @Override public TransportVersion getMinimalSupportedVersion() { - return TransportVersions.INFERENCE_USAGE_ADDED; + return TransportVersions.V_8_12_0; } } diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/inference/action/GetInferenceModelAction.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/inference/action/GetInferenceModelAction.java index 3fb753c1af2dd..503e4d7780e3f 100644 --- a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/inference/action/GetInferenceModelAction.java +++ b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/inference/action/GetInferenceModelAction.java @@ -87,7 +87,7 @@ public Response(List models) { public Response(StreamInput in) throws IOException { super(in); - if (in.getTransportVersion().onOrAfter(TransportVersions.ML_INFERENCE_GET_MULTIPLE_MODELS)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { models = in.readCollectionAsList(ModelConfigurations::new); } else { models = new ArrayList<>(); @@ -101,7 +101,7 @@ public List getModels() { @Override public void writeTo(StreamOutput out) throws IOException { - if (out.getTransportVersion().onOrAfter(TransportVersions.ML_INFERENCE_GET_MULTIPLE_MODELS)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeCollection(models); } else { models.get(0).writeTo(out); diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/inference/action/InferenceAction.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/inference/action/InferenceAction.java index 61be7d2f8fb4a..94af226b4a0e4 100644 --- a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/inference/action/InferenceAction.java +++ b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/inference/action/InferenceAction.java @@ -90,7 +90,7 @@ public Request(StreamInput in) throws IOException { super(in); this.taskType = TaskType.fromStream(in); this.inferenceEntityId = in.readString(); - if (in.getTransportVersion().onOrAfter(TransportVersions.INFERENCE_MULTIPLE_INPUTS)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { this.input = in.readStringCollectionAsList(); } else { this.input = List.of(in.readString()); @@ -143,7 +143,7 @@ public void writeTo(StreamOutput out) throws IOException { super.writeTo(out); taskType.writeTo(out); out.writeString(inferenceEntityId); - if (out.getTransportVersion().onOrAfter(TransportVersions.INFERENCE_MULTIPLE_INPUTS)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeStringCollection(input); } else { out.writeString(input.get(0)); @@ -233,12 +233,8 @@ public Response(InferenceServiceResults results) { public Response(StreamInput in) throws IOException { super(in); - if (in.getTransportVersion().onOrAfter(TransportVersions.INFERENCE_SERVICE_RESULTS_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { results = in.readNamedWriteable(InferenceServiceResults.class); - } else if (in.getTransportVersion().onOrAfter(TransportVersions.INFERENCE_MULTIPLE_INPUTS)) { - // This could be List aka List from ml plugin for - // hugging face elser and elser or the legacy format for openai - results = transformToServiceResults(in.readNamedWriteableCollectionAsList(InferenceResults.class)); } else { // It should only be InferenceResults aka TextEmbeddingResults from ml plugin for // hugging face elser and elser @@ -299,11 +295,8 @@ public InferenceServiceResults getResults() { @Override public void writeTo(StreamOutput out) throws IOException { - if (out.getTransportVersion().onOrAfter(TransportVersions.INFERENCE_SERVICE_RESULTS_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeNamedWriteable(results); - } else if (out.getTransportVersion().onOrAfter(TransportVersions.INFERENCE_MULTIPLE_INPUTS)) { - // This includes the legacy openai response format of List and hugging face elser and elser - out.writeNamedWriteableCollection(results.transformToLegacyFormat()); } else { out.writeNamedWriteable(results.transformToLegacyFormat().get(0)); } diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/inference/results/LegacyTextEmbeddingResults.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/inference/results/LegacyTextEmbeddingResults.java index 8f03a75c61c11..72a24fd916763 100644 --- a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/inference/results/LegacyTextEmbeddingResults.java +++ b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/inference/results/LegacyTextEmbeddingResults.java @@ -40,7 +40,7 @@ * } * * Legacy text embedding results represents what was returned prior to the - * {@link org.elasticsearch.TransportVersions#INFERENCE_SERVICE_RESULTS_ADDED} version. + * {@link org.elasticsearch.TransportVersions#V_8_12_0} version. * @deprecated use {@link TextEmbeddingResults} instead */ @Deprecated diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/action/InferModelAction.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/action/InferModelAction.java index a78ac06c2d76f..ba4e280862645 100644 --- a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/action/InferModelAction.java +++ b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/action/InferModelAction.java @@ -192,7 +192,7 @@ public Request(StreamInput in) throws IOException { if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_8_0)) { highPriority = in.readBoolean(); } - if (in.getTransportVersion().onOrAfter(TransportVersions.ML_TRAINED_MODEL_PREFIX_STRINGS_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { prefixType = in.readEnum(TrainedModelPrefixStrings.PrefixType.class); } else { prefixType = TrainedModelPrefixStrings.PrefixType.NONE; @@ -268,7 +268,7 @@ public void writeTo(StreamOutput out) throws IOException { if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_8_0)) { out.writeBoolean(highPriority); } - if (out.getTransportVersion().onOrAfter(TransportVersions.ML_TRAINED_MODEL_PREFIX_STRINGS_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeEnum(prefixType); } } diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/action/InferTrainedModelDeploymentAction.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/action/InferTrainedModelDeploymentAction.java index 2d7f1c4b52301..4209374740acc 100644 --- a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/action/InferTrainedModelDeploymentAction.java +++ b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/action/InferTrainedModelDeploymentAction.java @@ -159,7 +159,7 @@ public Request(StreamInput in) throws IOException { } else { textInput = null; } - if (in.getTransportVersion().onOrAfter(TransportVersions.ML_TRAINED_MODEL_PREFIX_STRINGS_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { prefixType = in.readEnum(TrainedModelPrefixStrings.PrefixType.class); } else { prefixType = TrainedModelPrefixStrings.PrefixType.NONE; @@ -255,7 +255,7 @@ public void writeTo(StreamOutput out) throws IOException { if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_7_0)) { out.writeOptionalStringCollection(textInput); } - if (out.getTransportVersion().onOrAfter(TransportVersions.ML_TRAINED_MODEL_PREFIX_STRINGS_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeEnum(prefixType); } if (out.getTransportVersion().onOrAfter(TransportVersions.NLP_DOCUMENT_CHUNKING_ADDED)) { diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/dataframe/DataFrameAnalyticsTaskState.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/dataframe/DataFrameAnalyticsTaskState.java index ad2d03a4b8f75..e61517569445b 100644 --- a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/dataframe/DataFrameAnalyticsTaskState.java +++ b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/dataframe/DataFrameAnalyticsTaskState.java @@ -84,7 +84,7 @@ public DataFrameAnalyticsTaskState(StreamInput in) throws IOException { this.state = DataFrameAnalyticsState.fromStream(in); this.allocationId = in.readLong(); this.reason = in.readOptionalString(); - if (in.getTransportVersion().onOrAfter(TransportVersions.ML_STATE_CHANGE_TIMESTAMPS)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { lastStateChangeTime = in.readOptionalInstant(); } else { lastStateChangeTime = null; @@ -129,7 +129,7 @@ public void writeTo(StreamOutput out) throws IOException { state.writeTo(out); out.writeLong(allocationId); out.writeOptionalString(reason); - if (out.getTransportVersion().onOrAfter(TransportVersions.ML_STATE_CHANGE_TIMESTAMPS)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeOptionalInstant(lastStateChangeTime); } } diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/inference/TrainedModelConfig.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/inference/TrainedModelConfig.java index b9fddd3ea30a2..80fd28f3ab03e 100644 --- a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/inference/TrainedModelConfig.java +++ b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/inference/TrainedModelConfig.java @@ -298,7 +298,7 @@ public TrainedModelConfig(StreamInput in) throws IOException { } else { platformArchitecture = null; } - if (in.getTransportVersion().onOrAfter(TransportVersions.ML_TRAINED_MODEL_PREFIX_STRINGS_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { prefixStrings = in.readOptionalWriteable(TrainedModelPrefixStrings::new); } } @@ -486,7 +486,7 @@ public void writeTo(StreamOutput out) throws IOException { out.writeOptionalString(platformArchitecture); } - if (out.getTransportVersion().onOrAfter(TransportVersions.ML_TRAINED_MODEL_PREFIX_STRINGS_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeOptionalWriteable(prefixStrings); } } diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/inference/trainedmodel/ModelPackageConfig.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/inference/trainedmodel/ModelPackageConfig.java index 5087ac025915c..d921bc1d4a158 100644 --- a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/inference/trainedmodel/ModelPackageConfig.java +++ b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/inference/trainedmodel/ModelPackageConfig.java @@ -183,7 +183,7 @@ public ModelPackageConfig(StreamInput in) throws IOException { } else { platformArchitecture = null; } - if (in.getTransportVersion().onOrAfter(TransportVersions.ML_TRAINED_MODEL_PREFIX_STRINGS_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { prefixStrings = in.readOptionalWriteable(TrainedModelPrefixStrings::new); } else { prefixStrings = null; @@ -311,7 +311,7 @@ public void writeTo(StreamOutput out) throws IOException { if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_11_X)) { out.writeOptionalString(platformArchitecture); } - if (out.getTransportVersion().onOrAfter(TransportVersions.ML_TRAINED_MODEL_PREFIX_STRINGS_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeOptionalWriteable(prefixStrings); } } diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/job/config/JobTaskState.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/job/config/JobTaskState.java index 41fd38ca1398c..2d03d4273013d 100644 --- a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/job/config/JobTaskState.java +++ b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/job/config/JobTaskState.java @@ -80,7 +80,7 @@ public JobTaskState(StreamInput in) throws IOException { state = JobState.fromStream(in); allocationId = in.readLong(); reason = in.readOptionalString(); - if (in.getTransportVersion().onOrAfter(TransportVersions.ML_STATE_CHANGE_TIMESTAMPS)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { lastStateChangeTime = in.readOptionalInstant(); } else { lastStateChangeTime = null; @@ -136,7 +136,7 @@ public void writeTo(StreamOutput out) throws IOException { state.writeTo(out); out.writeLong(allocationId); out.writeOptionalString(reason); - if (out.getTransportVersion().onOrAfter(TransportVersions.ML_STATE_CHANGE_TIMESTAMPS)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeOptionalInstant(lastStateChangeTime); } } diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/security/action/Grant.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/security/action/Grant.java index 41f1f50b6f7f0..b186ab45a7dc7 100644 --- a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/security/action/Grant.java +++ b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/security/action/Grant.java @@ -68,7 +68,7 @@ public Grant(StreamInput in) throws IOException { } else { this.runAsUsername = null; } - if (in.getTransportVersion().onOrAfter(TransportVersions.GRANT_API_KEY_CLIENT_AUTHENTICATION_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { this.clientAuthentication = in.readOptionalWriteable(ClientAuthentication::new); } else { this.clientAuthentication = null; @@ -83,7 +83,7 @@ public void writeTo(StreamOutput out) throws IOException { if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_4_0)) { out.writeOptionalString(runAsUsername); } - if (out.getTransportVersion().onOrAfter(TransportVersions.GRANT_API_KEY_CLIENT_AUTHENTICATION_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeOptionalWriteable(clientAuthentication); } } diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/security/action/apikey/ApiKey.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/security/action/apikey/ApiKey.java index 5753fa3b4ad7a..a2df837448754 100644 --- a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/security/action/apikey/ApiKey.java +++ b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/security/action/apikey/ApiKey.java @@ -182,7 +182,7 @@ public ApiKey(StreamInput in) throws IOException { this.creation = in.readInstant(); this.expiration = in.readOptionalInstant(); this.invalidated = in.readBoolean(); - if (in.getTransportVersion().onOrAfter(TransportVersions.GET_API_KEY_INVALIDATION_TIME_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { this.invalidation = in.readOptionalInstant(); } else { this.invalidation = null; @@ -337,7 +337,7 @@ public void writeTo(StreamOutput out) throws IOException { out.writeInstant(creation); out.writeOptionalInstant(expiration); out.writeBoolean(invalidated); - if (out.getTransportVersion().onOrAfter(TransportVersions.GET_API_KEY_INVALIDATION_TIME_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeOptionalInstant(invalidation); } out.writeString(username); diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/transform/action/GetCheckpointAction.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/transform/action/GetCheckpointAction.java index f1b11daf9e732..61be7cb3fe69e 100644 --- a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/transform/action/GetCheckpointAction.java +++ b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/transform/action/GetCheckpointAction.java @@ -59,16 +59,13 @@ public Request(StreamInput in) throws IOException { super(in); indices = in.readStringArray(); indicesOptions = IndicesOptions.readIndicesOptions(in); - if (in.getTransportVersion().onOrAfter(TransportVersions.TRANSFORM_GET_CHECKPOINT_QUERY_AND_CLUSTER_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { query = in.readOptionalNamedWriteable(QueryBuilder.class); cluster = in.readOptionalString(); + timeout = in.readOptionalTimeValue(); } else { query = null; cluster = null; - } - if (in.getTransportVersion().onOrAfter(TransportVersions.TRANSFORM_GET_CHECKPOINT_TIMEOUT_ADDED)) { - timeout = in.readOptionalTimeValue(); - } else { timeout = null; } } @@ -135,11 +132,9 @@ public void writeTo(StreamOutput out) throws IOException { super.writeTo(out); out.writeStringArray(indices); indicesOptions.writeIndicesOptions(out); - if (out.getTransportVersion().onOrAfter(TransportVersions.TRANSFORM_GET_CHECKPOINT_QUERY_AND_CLUSTER_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeOptionalNamedWriteable(query); out.writeOptionalString(cluster); - } - if (out.getTransportVersion().onOrAfter(TransportVersions.TRANSFORM_GET_CHECKPOINT_TIMEOUT_ADDED)) { out.writeOptionalTimeValue(timeout); } } diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/transform/action/GetCheckpointNodeAction.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/transform/action/GetCheckpointNodeAction.java index 908810cacf2ec..bdf0dd48886b4 100644 --- a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/transform/action/GetCheckpointNodeAction.java +++ b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/transform/action/GetCheckpointNodeAction.java @@ -104,7 +104,7 @@ public Request(StreamInput in) throws IOException { super(in); this.shards = in.readCollectionAsImmutableSet(ShardId::new); this.originalIndices = OriginalIndices.readOriginalIndices(in); - if (in.getTransportVersion().onOrAfter(TransportVersions.TRANSFORM_GET_CHECKPOINT_TIMEOUT_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { this.timeout = in.readOptionalTimeValue(); } else { this.timeout = null; @@ -121,7 +121,7 @@ public void writeTo(StreamOutput out) throws IOException { super.writeTo(out); out.writeCollection(shards); OriginalIndices.writeOriginalIndices(originalIndices, out); - if (out.getTransportVersion().onOrAfter(TransportVersions.TRANSFORM_GET_CHECKPOINT_TIMEOUT_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeOptionalTimeValue(timeout); } } diff --git a/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/ml/action/InferModelActionRequestTests.java b/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/ml/action/InferModelActionRequestTests.java index 4385867285592..2934d1dc9c42f 100644 --- a/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/ml/action/InferModelActionRequestTests.java +++ b/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/ml/action/InferModelActionRequestTests.java @@ -226,7 +226,7 @@ protected Request mutateInstanceForVersion(Request instance, TransportVersion ve ); r.setHighPriority(false); return r; - } else if (version.before(TransportVersions.ML_TRAINED_MODEL_PREFIX_STRINGS_ADDED)) { + } else if (version.before(TransportVersions.V_8_12_0)) { var r = new Request( instance.getId(), adjustedUpdate, diff --git a/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/ml/inference/TrainedModelConfigTests.java b/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/ml/inference/TrainedModelConfigTests.java index c900db5646ba8..a17ca18aba622 100644 --- a/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/ml/inference/TrainedModelConfigTests.java +++ b/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/ml/inference/TrainedModelConfigTests.java @@ -463,7 +463,7 @@ protected TrainedModelConfig mutateInstanceForVersion(TrainedModelConfig instanc if (version.before(TransportVersions.V_8_11_X)) { builder.setPlatformArchitecture(null); } - if (version.before(TransportVersions.ML_TRAINED_MODEL_PREFIX_STRINGS_ADDED)) { + if (version.before(TransportVersions.V_8_12_0)) { builder.setPrefixStrings(null); } return builder.build(); diff --git a/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/ml/inference/trainedmodel/ModelPackageConfigTests.java b/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/ml/inference/trainedmodel/ModelPackageConfigTests.java index 825313213f24d..88a9c7fb7b0ea 100644 --- a/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/ml/inference/trainedmodel/ModelPackageConfigTests.java +++ b/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/ml/inference/trainedmodel/ModelPackageConfigTests.java @@ -128,7 +128,7 @@ protected ModelPackageConfig mutateInstanceForVersion(ModelPackageConfig instanc if (version.before(TransportVersions.V_8_11_X)) { builder.setPlatformArchitecture(null); } - if (version.before(TransportVersions.ML_TRAINED_MODEL_PREFIX_STRINGS_ADDED)) { + if (version.before(TransportVersions.V_8_12_0)) { builder.setPrefixStrings(null); } return builder.build(); diff --git a/x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/DriverStatus.java b/x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/DriverStatus.java index 5a6265b37e3c6..90713381deb07 100644 --- a/x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/DriverStatus.java +++ b/x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/DriverStatus.java @@ -76,7 +76,7 @@ public DriverStatus(StreamInput in) throws IOException { this.sessionId = in.readString(); this.lastUpdated = in.readLong(); this.status = Status.valueOf(in.readString()); - if (in.getTransportVersion().onOrAfter(TransportVersions.ESQL_PROFILE)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { this.completedOperators = in.readCollectionAsImmutableList(OperatorStatus::new); } else { this.completedOperators = List.of(); @@ -89,7 +89,7 @@ public void writeTo(StreamOutput out) throws IOException { out.writeString(sessionId); out.writeLong(lastUpdated); out.writeString(status.toString()); - if (out.getTransportVersion().onOrAfter(TransportVersions.ESQL_PROFILE)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeCollection(completedOperators); } out.writeCollection(activeOperators); diff --git a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/action/EsqlQueryResponse.java b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/action/EsqlQueryResponse.java index 1763e36707958..7d8fdd5af7794 100644 --- a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/action/EsqlQueryResponse.java +++ b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/action/EsqlQueryResponse.java @@ -91,7 +91,7 @@ static EsqlQueryResponse deserialize(BlockStreamInput in) throws IOException { } List columns = in.readCollectionAsList(ColumnInfo::new); List pages = in.readCollectionAsList(Page::new); - if (in.getTransportVersion().onOrAfter(TransportVersions.ESQL_PROFILE)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { profile = in.readOptionalWriteable(Profile::new); } boolean columnar = in.readBoolean(); @@ -107,7 +107,7 @@ public void writeTo(StreamOutput out) throws IOException { } out.writeCollection(columns); out.writeCollection(pages); - if (out.getTransportVersion().onOrAfter(TransportVersions.ESQL_PROFILE)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeOptionalWriteable(profile); } out.writeBoolean(columnar); diff --git a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plugin/ComputeResponse.java b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plugin/ComputeResponse.java index 44796ca78aa91..a4235d85cf832 100644 --- a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plugin/ComputeResponse.java +++ b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plugin/ComputeResponse.java @@ -28,7 +28,7 @@ final class ComputeResponse extends TransportResponse { ComputeResponse(StreamInput in) throws IOException { super(in); - if (in.getTransportVersion().onOrAfter(TransportVersions.ESQL_PROFILE)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { if (in.readBoolean()) { profiles = in.readCollectionAsImmutableList(DriverProfile::new); } else { @@ -41,7 +41,7 @@ final class ComputeResponse extends TransportResponse { @Override public void writeTo(StreamOutput out) throws IOException { - if (out.getTransportVersion().onOrAfter(TransportVersions.ESQL_PROFILE)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { if (profiles == null) { out.writeBoolean(false); } else { diff --git a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/querydsl/query/SingleValueQuery.java b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/querydsl/query/SingleValueQuery.java index bc5f7349db8c1..7569d8d3335be 100644 --- a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/querydsl/query/SingleValueQuery.java +++ b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/querydsl/query/SingleValueQuery.java @@ -145,7 +145,7 @@ public static class Builder extends AbstractQueryBuilder { this.next = in.readNamedWriteable(QueryBuilder.class); this.field = in.readString(); this.stats = new Stats(); - if (in.getTransportVersion().onOrAfter(TransportVersions.SOURCE_IN_SINGLE_VALUE_QUERY_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { this.source = readSource(in); } else { this.source = Source.EMPTY; @@ -157,7 +157,7 @@ public static class Builder extends AbstractQueryBuilder { protected void doWriteTo(StreamOutput out) throws IOException { out.writeNamedWriteable(next); out.writeString(field); - if (out.getTransportVersion().onOrAfter(TransportVersions.SOURCE_IN_SINGLE_VALUE_QUERY_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { writeSource(out, source); } } diff --git a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session/EsqlConfiguration.java b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session/EsqlConfiguration.java index ccec6554cb2cb..5bf126ade0b74 100644 --- a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session/EsqlConfiguration.java +++ b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session/EsqlConfiguration.java @@ -67,7 +67,7 @@ public EsqlConfiguration(StreamInput in) throws IOException { this.resultTruncationMaxSize = in.readVInt(); this.resultTruncationDefaultSize = in.readVInt(); this.query = readQuery(in); - if (in.getTransportVersion().onOrAfter(TransportVersions.ESQL_PROFILE)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { this.profile = in.readBoolean(); } else { this.profile = false; @@ -87,7 +87,7 @@ public void writeTo(StreamOutput out) throws IOException { out.writeVInt(resultTruncationMaxSize); out.writeVInt(resultTruncationDefaultSize); writeQuery(out, query); - if (out.getTransportVersion().onOrAfter(TransportVersions.ESQL_PROFILE)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeBoolean(profile); } } diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/elser/ElserInternalService.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/elser/ElserInternalService.java index 0229a0eb1c0cb..e5adc58c1bb76 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/elser/ElserInternalService.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/elser/ElserInternalService.java @@ -386,6 +386,6 @@ public void close() throws IOException {} @Override public TransportVersion getMinimalSupportedVersion() { - return TransportVersions.ELSER_SERVICE_MODEL_VERSION_ADDED; + return TransportVersions.V_8_12_0; } } diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/elser/ElserInternalServiceSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/elser/ElserInternalServiceSettings.java index 3f345a4410091..d0534610aa041 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/elser/ElserInternalServiceSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/elser/ElserInternalServiceSettings.java @@ -69,22 +69,10 @@ public ElserInternalServiceSettings(StreamInput in) throws IOException { super( in.readVInt(), in.readVInt(), - transportVersionIsCompatibleWithElserModelVersion(in.getTransportVersion()) - ? in.readString() - : ElserInternalService.ELSER_V2_MODEL + in.getTransportVersion().onOrAfter(TransportVersions.V_8_11_X) ? in.readString() : ElserInternalService.ELSER_V2_MODEL ); } - static boolean transportVersionIsCompatibleWithElserModelVersion(TransportVersion transportVersion) { - var nextNonPatchVersion = TransportVersions.PLUGIN_DESCRIPTOR_OPTIONAL_CLASSNAME; - - if (transportVersion.onOrAfter(TransportVersions.ELSER_SERVICE_MODEL_VERSION_ADDED)) { - return true; - } else { - return transportVersion.onOrAfter(TransportVersions.V_8_11_X) && transportVersion.before(nextNonPatchVersion); - } - } - @Override public String getWriteableName() { return ElserInternalServiceSettings.NAME; @@ -99,7 +87,7 @@ public TransportVersion getMinimalSupportedVersion() { public void writeTo(StreamOutput out) throws IOException { out.writeVInt(getNumAllocations()); out.writeVInt(getNumThreads()); - if (transportVersionIsCompatibleWithElserModelVersion(out.getTransportVersion())) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_11_X)) { out.writeString(getModelId()); } } diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/HuggingFaceService.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/HuggingFaceService.java index 401c3754759a7..60f947e22da95 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/HuggingFaceService.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/HuggingFaceService.java @@ -77,6 +77,6 @@ public String name() { @Override public TransportVersion getMinimalSupportedVersion() { - return TransportVersions.ML_INFERENCE_HF_SERVICE_ADDED; + return TransportVersions.V_8_12_0; } } diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/HuggingFaceServiceSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/HuggingFaceServiceSettings.java index b3b130b22a1fa..115cafb26d258 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/HuggingFaceServiceSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/HuggingFaceServiceSettings.java @@ -86,7 +86,7 @@ public HuggingFaceServiceSettings(String url) { public HuggingFaceServiceSettings(StreamInput in) throws IOException { this.uri = createUri(in.readString()); - if (in.getTransportVersion().onOrAfter(TransportVersions.INFERENCE_SERVICE_EMBEDDING_SIZE_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { similarity = in.readOptionalEnum(SimilarityMeasure.class); dimensions = in.readOptionalVInt(); maxInputTokens = in.readOptionalVInt(); @@ -121,13 +121,13 @@ public String getWriteableName() { @Override public TransportVersion getMinimalSupportedVersion() { - return TransportVersions.ML_INFERENCE_HF_SERVICE_ADDED; + return TransportVersions.V_8_12_0; } @Override public void writeTo(StreamOutput out) throws IOException { out.writeString(uri.toString()); - if (out.getTransportVersion().onOrAfter(TransportVersions.INFERENCE_SERVICE_EMBEDDING_SIZE_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeOptionalEnum(similarity); out.writeOptionalVInt(dimensions); out.writeOptionalVInt(maxInputTokens); diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/elser/HuggingFaceElserSecretSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/elser/HuggingFaceElserSecretSettings.java index bf024e97f1e0a..e6560a9dd1af6 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/elser/HuggingFaceElserSecretSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/elser/HuggingFaceElserSecretSettings.java @@ -67,7 +67,7 @@ public XContentBuilder toXContent(XContentBuilder builder, Params params) throws @Override public TransportVersion getMinimalSupportedVersion() { - return TransportVersions.ML_INFERENCE_TASK_SETTINGS_OPTIONAL_ADDED; + return TransportVersions.V_8_12_0; } @Override diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/elser/HuggingFaceElserService.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/elser/HuggingFaceElserService.java index 579745ea7f4fe..68407d8a2e029 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/elser/HuggingFaceElserService.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/elser/HuggingFaceElserService.java @@ -49,6 +49,6 @@ protected HuggingFaceModel createModel( @Override public TransportVersion getMinimalSupportedVersion() { - return TransportVersions.ML_INFERENCE_TASK_SETTINGS_OPTIONAL_ADDED; + return TransportVersions.V_8_12_0; } } diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/elser/HuggingFaceElserServiceSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/elser/HuggingFaceElserServiceSettings.java index 03bc6290f5dc2..6fc415123664e 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/elser/HuggingFaceElserServiceSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/elser/HuggingFaceElserServiceSettings.java @@ -69,7 +69,7 @@ public String getWriteableName() { @Override public TransportVersion getMinimalSupportedVersion() { - return TransportVersions.ML_INFERENCE_TASK_SETTINGS_OPTIONAL_ADDED; + return TransportVersions.V_8_12_0; } @Override diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/openai/OpenAiService.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/openai/OpenAiService.java index 9fe5dba2ac030..f132dcdfd37c9 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/openai/OpenAiService.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/openai/OpenAiService.java @@ -219,6 +219,6 @@ private OpenAiEmbeddingsModel updateModelWithEmbeddingDetails(OpenAiEmbeddingsMo @Override public TransportVersion getMinimalSupportedVersion() { - return TransportVersions.ML_INFERENCE_OPENAI_ADDED; + return TransportVersions.V_8_12_0; } } diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/openai/OpenAiServiceSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/openai/OpenAiServiceSettings.java index 4e96ac73157ad..50348ca5a0264 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/openai/OpenAiServiceSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/openai/OpenAiServiceSettings.java @@ -92,7 +92,7 @@ public OpenAiServiceSettings( public OpenAiServiceSettings(StreamInput in) throws IOException { uri = createOptionalUri(in.readOptionalString()); organizationId = in.readOptionalString(); - if (in.getTransportVersion().onOrAfter(TransportVersions.INFERENCE_SERVICE_EMBEDDING_SIZE_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { similarity = in.readOptionalEnum(SimilarityMeasure.class); dimensions = in.readOptionalVInt(); maxInputTokens = in.readOptionalVInt(); @@ -154,7 +154,7 @@ public XContentBuilder toXContent(XContentBuilder builder, Params params) throws @Override public TransportVersion getMinimalSupportedVersion() { - return TransportVersions.ML_INFERENCE_OPENAI_ADDED; + return TransportVersions.V_8_12_0; } @Override @@ -162,7 +162,7 @@ public void writeTo(StreamOutput out) throws IOException { var uriToWrite = uri != null ? uri.toString() : null; out.writeOptionalString(uriToWrite); out.writeOptionalString(organizationId); - if (out.getTransportVersion().onOrAfter(TransportVersions.INFERENCE_SERVICE_EMBEDDING_SIZE_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeOptionalEnum(similarity); out.writeOptionalVInt(dimensions); out.writeOptionalVInt(maxInputTokens); diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/openai/embeddings/OpenAiEmbeddingsTaskSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/openai/embeddings/OpenAiEmbeddingsTaskSettings.java index d0042ff57efe2..12445e89109b0 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/openai/embeddings/OpenAiEmbeddingsTaskSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/openai/embeddings/OpenAiEmbeddingsTaskSettings.java @@ -116,7 +116,7 @@ public String getWriteableName() { @Override public TransportVersion getMinimalSupportedVersion() { - return TransportVersions.ML_INFERENCE_OPENAI_ADDED; + return TransportVersions.V_8_12_0; } @Override diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/settings/DefaultSecretSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/settings/DefaultSecretSettings.java index 2689634d75d98..8587f254c0b4d 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/settings/DefaultSecretSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/settings/DefaultSecretSettings.java @@ -71,7 +71,7 @@ public XContentBuilder toXContent(XContentBuilder builder, Params params) throws @Override public TransportVersion getMinimalSupportedVersion() { - return TransportVersions.ML_INFERENCE_OPENAI_ADDED; + return TransportVersions.V_8_12_0; } @Override diff --git a/x-pack/plugin/inference/src/test/java/org/elasticsearch/xpack/inference/action/InferenceActionRequestTests.java b/x-pack/plugin/inference/src/test/java/org/elasticsearch/xpack/inference/action/InferenceActionRequestTests.java index dd7be116d8175..ea98614516d15 100644 --- a/x-pack/plugin/inference/src/test/java/org/elasticsearch/xpack/inference/action/InferenceActionRequestTests.java +++ b/x-pack/plugin/inference/src/test/java/org/elasticsearch/xpack/inference/action/InferenceActionRequestTests.java @@ -142,7 +142,7 @@ protected InferenceAction.Request mutateInstance(InferenceAction.Request instanc @Override protected InferenceAction.Request mutateInstanceForVersion(InferenceAction.Request instance, TransportVersion version) { - if (version.before(TransportVersions.INFERENCE_MULTIPLE_INPUTS)) { + if (version.before(TransportVersions.V_8_12_0)) { return new InferenceAction.Request( instance.getTaskType(), instance.getInferenceEntityId(), diff --git a/x-pack/plugin/inference/src/test/java/org/elasticsearch/xpack/inference/action/InferenceActionResponseTests.java b/x-pack/plugin/inference/src/test/java/org/elasticsearch/xpack/inference/action/InferenceActionResponseTests.java index 759411cec1212..7016122fedcf8 100644 --- a/x-pack/plugin/inference/src/test/java/org/elasticsearch/xpack/inference/action/InferenceActionResponseTests.java +++ b/x-pack/plugin/inference/src/test/java/org/elasticsearch/xpack/inference/action/InferenceActionResponseTests.java @@ -22,10 +22,7 @@ import java.util.ArrayList; import java.util.List; -import static org.elasticsearch.TransportVersions.INFERENCE_MULTIPLE_INPUTS; -import static org.elasticsearch.TransportVersions.INFERENCE_SERVICE_RESULTS_ADDED; -import static org.elasticsearch.TransportVersions.ML_INFERENCE_OPENAI_ADDED; -import static org.elasticsearch.TransportVersions.ML_INFERENCE_TASK_SETTINGS_OPTIONAL_ADDED; +import static org.elasticsearch.TransportVersions.V_8_12_0; import static org.elasticsearch.xpack.core.inference.action.InferenceAction.Response.transformToServiceResults; public class InferenceActionResponseTests extends AbstractBWCWireSerializationTestCase { @@ -61,7 +58,7 @@ protected InferenceAction.Response mutateInstance(InferenceAction.Response insta @Override protected InferenceAction.Response mutateInstanceForVersion(InferenceAction.Response instance, TransportVersion version) { - if (version.before(INFERENCE_MULTIPLE_INPUTS)) { + if (version.before(V_8_12_0)) { var singleResultList = instance.getResults().transformToLegacyFormat().subList(0, 1); return new InferenceAction.Response(transformToServiceResults(singleResultList)); } @@ -71,36 +68,36 @@ protected InferenceAction.Response mutateInstanceForVersion(InferenceAction.Resp public void testSerializesInferenceServiceResultsAddedVersion() throws IOException { var instance = createTestInstance(); - var copy = copyWriteable(instance, getNamedWriteableRegistry(), instanceReader(), INFERENCE_SERVICE_RESULTS_ADDED); - assertOnBWCObject(copy, instance, INFERENCE_SERVICE_RESULTS_ADDED); + var copy = copyWriteable(instance, getNamedWriteableRegistry(), instanceReader(), V_8_12_0); + assertOnBWCObject(copy, instance, V_8_12_0); } public void testSerializesOpenAiAddedVersion_UsingLegacyTextEmbeddingResult() throws IOException { var embeddingResults = LegacyTextEmbeddingResultsTests.createRandomResults().transformToTextEmbeddingResults(); var instance = new InferenceAction.Response(embeddingResults); - var copy = copyWriteable(instance, getNamedWriteableRegistry(), instanceReader(), ML_INFERENCE_OPENAI_ADDED); - assertOnBWCObject(copy, instance, ML_INFERENCE_OPENAI_ADDED); + var copy = copyWriteable(instance, getNamedWriteableRegistry(), instanceReader(), V_8_12_0); + assertOnBWCObject(copy, instance, V_8_12_0); } public void testSerializesOpenAiAddedVersion_UsingSparseEmbeddingResult() throws IOException { var embeddingResults = SparseEmbeddingResultsTests.createRandomResults(); var instance = new InferenceAction.Response(embeddingResults); - var copy = copyWriteable(instance, getNamedWriteableRegistry(), instanceReader(), ML_INFERENCE_OPENAI_ADDED); - assertOnBWCObject(copy, instance, ML_INFERENCE_OPENAI_ADDED); + var copy = copyWriteable(instance, getNamedWriteableRegistry(), instanceReader(), V_8_12_0); + assertOnBWCObject(copy, instance, V_8_12_0); } public void testSerializesMultipleInputsVersion_UsingLegacyTextEmbeddingResult() throws IOException { var embeddingResults = TextEmbeddingResultsTests.createRandomResults(); var instance = new InferenceAction.Response(embeddingResults); - var copy = copyWriteable(instance, getNamedWriteableRegistry(), instanceReader(), INFERENCE_MULTIPLE_INPUTS); - assertOnBWCObject(copy, instance, INFERENCE_MULTIPLE_INPUTS); + var copy = copyWriteable(instance, getNamedWriteableRegistry(), instanceReader(), V_8_12_0); + assertOnBWCObject(copy, instance, V_8_12_0); } public void testSerializesMultipleInputsVersion_UsingSparseEmbeddingResult() throws IOException { var embeddingResults = SparseEmbeddingResultsTests.createRandomResults(); var instance = new InferenceAction.Response(embeddingResults); - var copy = copyWriteable(instance, getNamedWriteableRegistry(), instanceReader(), INFERENCE_MULTIPLE_INPUTS); - assertOnBWCObject(copy, instance, INFERENCE_MULTIPLE_INPUTS); + var copy = copyWriteable(instance, getNamedWriteableRegistry(), instanceReader(), V_8_12_0); + assertOnBWCObject(copy, instance, V_8_12_0); } // Technically we should never see a text embedding result in the transport version of this test because support @@ -108,14 +105,14 @@ public void testSerializesMultipleInputsVersion_UsingSparseEmbeddingResult() thr public void testSerializesSingleInputVersion_UsingLegacyTextEmbeddingResult() throws IOException { var embeddingResults = TextEmbeddingResultsTests.createRandomResults(); var instance = new InferenceAction.Response(embeddingResults); - var copy = copyWriteable(instance, getNamedWriteableRegistry(), instanceReader(), ML_INFERENCE_TASK_SETTINGS_OPTIONAL_ADDED); - assertOnBWCObject(copy, instance, ML_INFERENCE_TASK_SETTINGS_OPTIONAL_ADDED); + var copy = copyWriteable(instance, getNamedWriteableRegistry(), instanceReader(), V_8_12_0); + assertOnBWCObject(copy, instance, V_8_12_0); } public void testSerializesSingleVersion_UsingSparseEmbeddingResult() throws IOException { var embeddingResults = SparseEmbeddingResultsTests.createRandomResults().transformToLegacyFormat().subList(0, 1); var instance = new InferenceAction.Response(transformToServiceResults(embeddingResults)); - var copy = copyWriteable(instance, getNamedWriteableRegistry(), instanceReader(), ML_INFERENCE_TASK_SETTINGS_OPTIONAL_ADDED); - assertOnBWCObject(copy, instance, ML_INFERENCE_TASK_SETTINGS_OPTIONAL_ADDED); + var copy = copyWriteable(instance, getNamedWriteableRegistry(), instanceReader(), V_8_12_0); + assertOnBWCObject(copy, instance, V_8_12_0); } } diff --git a/x-pack/plugin/inference/src/test/java/org/elasticsearch/xpack/inference/services/elser/ElserInternalServiceSettingsTests.java b/x-pack/plugin/inference/src/test/java/org/elasticsearch/xpack/inference/services/elser/ElserInternalServiceSettingsTests.java index 3adb6481d945b..c0e425144a618 100644 --- a/x-pack/plugin/inference/src/test/java/org/elasticsearch/xpack/inference/services/elser/ElserInternalServiceSettingsTests.java +++ b/x-pack/plugin/inference/src/test/java/org/elasticsearch/xpack/inference/services/elser/ElserInternalServiceSettingsTests.java @@ -87,39 +87,12 @@ public void testFromMapMissingOptions() { assertThat(e.getMessage(), containsString("[service_settings] does not contain the required setting [num_allocations]")); } - public void testTransportVersionIsCompatibleWithElserModelVersion() { - assertTrue( - ElserInternalServiceSettings.transportVersionIsCompatibleWithElserModelVersion( - TransportVersions.ELSER_SERVICE_MODEL_VERSION_ADDED - ) - ); - assertTrue(ElserInternalServiceSettings.transportVersionIsCompatibleWithElserModelVersion(TransportVersions.V_8_11_X)); - - assertFalse(ElserInternalServiceSettings.transportVersionIsCompatibleWithElserModelVersion(TransportVersions.V_8_10_X)); - assertFalse( - ElserInternalServiceSettings.transportVersionIsCompatibleWithElserModelVersion( - TransportVersions.PLUGIN_DESCRIPTOR_OPTIONAL_CLASSNAME - ) - ); - assertFalse( - ElserInternalServiceSettings.transportVersionIsCompatibleWithElserModelVersion( - TransportVersions.UNIVERSAL_PROFILING_LICENSE_ADDED - ) - ); - } - public void testBwcWrite() throws IOException { { var settings = new ElserInternalServiceSettings(1, 1, ".elser_model_1"); - var copy = copyInstance(settings, TransportVersions.ELSER_SERVICE_MODEL_VERSION_ADDED); + var copy = copyInstance(settings, TransportVersions.V_8_12_0); assertEquals(settings, copy); } - { - var settings = new ElserInternalServiceSettings(1, 1, ".elser_model_1"); - var copy = copyInstance(settings, TransportVersions.PLUGIN_DESCRIPTOR_OPTIONAL_CLASSNAME); - assertNotEquals(settings, copy); - assertEquals(".elser_model_2", copy.getModelId()); - } { var settings = new ElserInternalServiceSettings(1, 1, ".elser_model_1"); var copy = copyInstance(settings, TransportVersions.V_8_11_X); diff --git a/x-pack/plugin/snapshot-repo-test-kit/src/main/java/org/elasticsearch/repositories/blobstore/testkit/RepositoryAnalyzeAction.java b/x-pack/plugin/snapshot-repo-test-kit/src/main/java/org/elasticsearch/repositories/blobstore/testkit/RepositoryAnalyzeAction.java index 5e7f5dfdc855d..51fe98b86b536 100644 --- a/x-pack/plugin/snapshot-repo-test-kit/src/main/java/org/elasticsearch/repositories/blobstore/testkit/RepositoryAnalyzeAction.java +++ b/x-pack/plugin/snapshot-repo-test-kit/src/main/java/org/elasticsearch/repositories/blobstore/testkit/RepositoryAnalyzeAction.java @@ -504,7 +504,7 @@ public void run() { } } - if (minClusterTransportVersion.onOrAfter(TransportVersions.UNCONTENDED_REGISTER_ANALYSIS_ADDED)) { + if (minClusterTransportVersion.onOrAfter(TransportVersions.V_8_12_0)) { new UncontendedRegisterAnalysis(new Random(random.nextLong()), nodes, contendedRegisterAnalysisComplete).run(); } } @@ -913,7 +913,7 @@ public Request(StreamInput in) throws IOException { rareActionProbability = in.readDouble(); blobCount = in.readVInt(); concurrency = in.readVInt(); - if (in.getTransportVersion().onOrAfter(TransportVersions.REPO_ANALYSIS_REGISTER_OP_COUNT_ADDED)) { + if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { registerOperationCount = in.readVInt(); } else { registerOperationCount = concurrency; @@ -945,7 +945,7 @@ public void writeTo(StreamOutput out) throws IOException { out.writeDouble(rareActionProbability); out.writeVInt(blobCount); out.writeVInt(concurrency); - if (out.getTransportVersion().onOrAfter(TransportVersions.REPO_ANALYSIS_REGISTER_OP_COUNT_ADDED)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0)) { out.writeVInt(registerOperationCount); } else if (registerOperationCount != concurrency) { throw new IllegalArgumentException( diff --git a/x-pack/plugin/snapshot-repo-test-kit/src/main/java/org/elasticsearch/repositories/blobstore/testkit/UncontendedRegisterAnalyzeAction.java b/x-pack/plugin/snapshot-repo-test-kit/src/main/java/org/elasticsearch/repositories/blobstore/testkit/UncontendedRegisterAnalyzeAction.java index 8e92384532763..1986b47e3188c 100644 --- a/x-pack/plugin/snapshot-repo-test-kit/src/main/java/org/elasticsearch/repositories/blobstore/testkit/UncontendedRegisterAnalyzeAction.java +++ b/x-pack/plugin/snapshot-repo-test-kit/src/main/java/org/elasticsearch/repositories/blobstore/testkit/UncontendedRegisterAnalyzeAction.java @@ -150,7 +150,7 @@ static class Request extends ActionRequest { Request(StreamInput in) throws IOException { super(in); - assert in.getTransportVersion().onOrAfter(TransportVersions.UNCONTENDED_REGISTER_ANALYSIS_ADDED); + assert in.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0); repositoryName = in.readString(); containerPath = in.readString(); registerName = in.readString(); @@ -159,7 +159,7 @@ static class Request extends ActionRequest { @Override public void writeTo(StreamOutput out) throws IOException { - assert out.getTransportVersion().onOrAfter(TransportVersions.UNCONTENDED_REGISTER_ANALYSIS_ADDED); + assert out.getTransportVersion().onOrAfter(TransportVersions.V_8_12_0); super.writeTo(out); out.writeString(repositoryName); out.writeString(containerPath); diff --git a/x-pack/plugin/spatial/src/main/java/org/elasticsearch/xpack/spatial/index/fielddata/ShapeValues.java b/x-pack/plugin/spatial/src/main/java/org/elasticsearch/xpack/spatial/index/fielddata/ShapeValues.java index 0c1bb45ffbd8d..05d895120a8c1 100644 --- a/x-pack/plugin/spatial/src/main/java/org/elasticsearch/xpack/spatial/index/fielddata/ShapeValues.java +++ b/x-pack/plugin/spatial/src/main/java/org/elasticsearch/xpack/spatial/index/fielddata/ShapeValues.java @@ -208,7 +208,7 @@ public XContentBuilder toXContent(XContentBuilder builder, Params params) throws @Override public TransportVersion getMinimalSupportedVersion() { - return TransportVersions.SHAPE_VALUE_SERIALIZATION_ADDED; + return TransportVersions.V_8_12_0; } @Override diff --git a/x-pack/plugin/spatial/src/test/java/org/elasticsearch/xpack/spatial/index/fielddata/ShapeValuesGenericWriteableTests.java b/x-pack/plugin/spatial/src/test/java/org/elasticsearch/xpack/spatial/index/fielddata/ShapeValuesGenericWriteableTests.java index cb123ad724dc0..35294d07aa53f 100644 --- a/x-pack/plugin/spatial/src/test/java/org/elasticsearch/xpack/spatial/index/fielddata/ShapeValuesGenericWriteableTests.java +++ b/x-pack/plugin/spatial/src/test/java/org/elasticsearch/xpack/spatial/index/fielddata/ShapeValuesGenericWriteableTests.java @@ -67,8 +67,7 @@ protected GenericWriteableWrapper copyInstance(GenericWriteableWrapper instance, protected abstract String shapeValueName(); public void testSerializationFailsWithOlderVersion() { - TransportVersion older = TransportVersions.KNN_AS_QUERY_ADDED; - assert older.before(TransportVersions.SHAPE_VALUE_SERIALIZATION_ADDED); + TransportVersion older = TransportVersions.V_8_11_X; final var testInstance = createTestInstance().shapeValue(); try (var output = new BytesStreamOutput()) { output.setTransportVersion(older);