diff --git a/server/src/main/java/org/elasticsearch/TransportVersions.java b/server/src/main/java/org/elasticsearch/TransportVersions.java index a6fa7a9ea8e99..c4fb04c47473b 100644 --- a/server/src/main/java/org/elasticsearch/TransportVersions.java +++ b/server/src/main/java/org/elasticsearch/TransportVersions.java @@ -120,6 +120,7 @@ static TransportVersion def(int id) { public static final TransportVersion DESIRED_NODE_VERSION_OPTIONAL_STRING = def(8_580_00_0); public static final TransportVersion ML_INFERENCE_REQUEST_INPUT_TYPE_UNSPECIFIED_ADDED = def(8_581_00_0); public static final TransportVersion ASYNC_SEARCH_STATUS_SUPPORTS_KEEP_ALIVE = def(8_582_00_0); + public static final TransportVersion TIME_SERIES_ID_HASHING = def(8_582_10_0); public static final TransportVersion KNN_QUERY_NUMCANDS_AS_OPTIONAL_PARAM = def(8_583_00_0); public static final TransportVersion TRANSFORM_GET_BASIC_STATS = def(8_584_00_0); public static final TransportVersion NLP_DOCUMENT_CHUNKING_ADDED = def(8_585_00_0); diff --git a/x-pack/plugin/downsample/src/main/java/org/elasticsearch/xpack/downsample/DownsampleShardTaskParams.java b/x-pack/plugin/downsample/src/main/java/org/elasticsearch/xpack/downsample/DownsampleShardTaskParams.java index 93be79e859f8d..c0c281075e8d0 100644 --- a/x-pack/plugin/downsample/src/main/java/org/elasticsearch/xpack/downsample/DownsampleShardTaskParams.java +++ b/x-pack/plugin/downsample/src/main/java/org/elasticsearch/xpack/downsample/DownsampleShardTaskParams.java @@ -37,7 +37,6 @@ public record DownsampleShardTaskParams( String[] dimensions ) implements PersistentTaskParams { - private static final TransportVersion V_8_13_0 = TransportVersions.ML_MODEL_IN_SERVICE_SETTINGS; public static final String NAME = DownsampleShardTask.TASK_NAME; private static final ParseField DOWNSAMPLE_CONFIG = new ParseField("downsample_config"); private static final ParseField DOWNSAMPLE_INDEX = new ParseField("rollup_index"); @@ -73,7 +72,7 @@ public record DownsampleShardTaskParams( new ShardId(in), in.readStringArray(), in.readStringArray(), - in.getTransportVersion().onOrAfter(V_8_13_0) ? in.readOptionalStringArray() : new String[] {} + in.getTransportVersion().onOrAfter(TransportVersions.TIME_SERIES_ID_HASHING) ? in.readOptionalStringArray() : new String[] {} ); } @@ -112,7 +111,7 @@ public void writeTo(StreamOutput out) throws IOException { shardId.writeTo(out); out.writeStringArray(metrics); out.writeStringArray(labels); - if (out.getTransportVersion().onOrAfter(V_8_13_0)) { + if (out.getTransportVersion().onOrAfter(TransportVersions.TIME_SERIES_ID_HASHING)) { out.writeOptionalStringArray(dimensions); } }