Skip to content

Commit d2622a6

Browse files
authored
[9.1] Migrate transport version (elastic#134388) (elastic#134396)
Backports the following commits to 9.1: - Migrate transport version (elastic#134388)
1 parent b861586 commit d2622a6

File tree

4 files changed

+5
-3
lines changed

4 files changed

+5
-3
lines changed

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

Lines changed: 0 additions & 1 deletion
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

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

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

Lines changed: 3 additions & 2 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,7 +249,7 @@ public TransportVersion getMinimalSupportedVersion() {
248249

249250
@Override
250251
public boolean supportsVersion(TransportVersion version) {
251-
return version.onOrAfter(TransportVersions.ESQL_SAMPLE_OPERATOR_STATUS_9_1);
252+
return version.supports(ESQL_SAMPLE_OPERATOR_STATUS);
252253
}
253254
}
254255
}

0 commit comments

Comments
 (0)