Skip to content

Commit 63a11de

Browse files
authored
Migrate transport version (#134388)
Migrates: * ESQL_SAMPLE_OPERATOR_STATUS and ESQL_SAMPLE_OPERATOR_STATUS_9_1
1 parent 5ea0f5d commit 63a11de

File tree

3 files changed

+4
-5
lines changed

3 files changed

+4
-5
lines changed

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

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -326,7 +326,6 @@ static TransportVersion def(int id) {
326326
public static final TransportVersion MAPPINGS_IN_DATA_STREAMS = def(9_112_0_00);
327327
public static final TransportVersion ESQL_SPLIT_ON_BIG_VALUES_9_1 = def(9_112_0_01);
328328
public static final TransportVersion ESQL_FIXED_INDEX_LIKE_9_1 = def(9_112_0_02);
329-
public static final TransportVersion ESQL_SAMPLE_OPERATOR_STATUS_9_1 = def(9_112_0_03);
330329
public static final TransportVersion INITIAL_ELASTICSEARCH_9_1_4 = def(9_112_0_07);
331330
public static final TransportVersion PROJECT_STATE_REGISTRY_RECORDS_DELETIONS = def(9_113_0_00);
332331
public static final TransportVersion ESQL_SERIALIZE_TIMESERIES_FIELD_TYPE = def(9_114_0_00);
@@ -342,7 +341,6 @@ static TransportVersion def(int id) {
342341
public static final TransportVersion PROJECT_STATE_REGISTRY_ENTRY = def(9_124_0_00);
343342
public static final TransportVersion ML_INFERENCE_LLAMA_ADDED = def(9_125_0_00);
344343
public static final TransportVersion SHARD_WRITE_LOAD_IN_CLUSTER_INFO = def(9_126_0_00);
345-
public static final TransportVersion ESQL_SAMPLE_OPERATOR_STATUS = def(9_127_0_00);
346344
public static final TransportVersion TIME_SERIES_TELEMETRY = def(9_155_0_00);
347345
public static final TransportVersion INFERENCE_API_EIS_DIAGNOSTICS = def(9_156_0_00);
348346

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
9127000,9112003

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/SampleOperator.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,6 @@
88
package org.elasticsearch.compute.operator;
99

1010
import org.elasticsearch.TransportVersion;
11-
import org.elasticsearch.TransportVersions;
1211
import org.elasticsearch.common.Randomness;
1312
import org.elasticsearch.common.Strings;
1413
import org.elasticsearch.common.io.stream.NamedWriteableRegistry;
@@ -177,6 +176,8 @@ public record Status(long collectNanos, long emitNanos, int pagesProcessed, long
177176
Status::new
178177
);
179178

179+
private static final TransportVersion ESQL_SAMPLE_OPERATOR_STATUS = TransportVersion.fromName("esql_sample_operator_status");
180+
180181
Status(StreamInput streamInput) throws IOException {
181182
this(
182183
streamInput.readVLong(),
@@ -248,8 +249,7 @@ public TransportVersion getMinimalSupportedVersion() {
248249

249250
@Override
250251
public boolean supportsVersion(TransportVersion version) {
251-
return version.onOrAfter(TransportVersions.ESQL_SAMPLE_OPERATOR_STATUS)
252-
|| version.isPatchFrom(TransportVersions.ESQL_SAMPLE_OPERATOR_STATUS_9_1);
252+
return version.supports(ESQL_SAMPLE_OPERATOR_STATUS);
253253
}
254254
}
255255
}

0 commit comments

Comments
 (0)