Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -326,7 +326,6 @@ static TransportVersion def(int id) {
public static final TransportVersion MAPPINGS_IN_DATA_STREAMS = def(9_112_0_00);
public static final TransportVersion ESQL_SPLIT_ON_BIG_VALUES_9_1 = def(9_112_0_01);
public static final TransportVersion ESQL_FIXED_INDEX_LIKE_9_1 = def(9_112_0_02);
public static final TransportVersion ESQL_SAMPLE_OPERATOR_STATUS_9_1 = def(9_112_0_03);
public static final TransportVersion INITIAL_ELASTICSEARCH_9_1_4 = def(9_112_0_07);

/*
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
9127000,9112003
1 change: 1 addition & 0 deletions server/src/main/resources/transport/upper_bounds/9.2.csv
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
esql_sample_operator_status,9127000
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@
package org.elasticsearch.compute.operator;

import org.elasticsearch.TransportVersion;
import org.elasticsearch.TransportVersions;
import org.elasticsearch.common.Randomness;
import org.elasticsearch.common.Strings;
import org.elasticsearch.common.io.stream.NamedWriteableRegistry;
Expand Down Expand Up @@ -177,6 +176,8 @@ public record Status(long collectNanos, long emitNanos, int pagesProcessed, long
Status::new
);

private static final TransportVersion ESQL_SAMPLE_OPERATOR_STATUS = TransportVersion.fromName("esql_sample_operator_status");

Status(StreamInput streamInput) throws IOException {
this(
streamInput.readVLong(),
Expand Down Expand Up @@ -248,7 +249,7 @@ public TransportVersion getMinimalSupportedVersion() {

@Override
public boolean supportsVersion(TransportVersion version) {
return version.onOrAfter(TransportVersions.ESQL_SAMPLE_OPERATOR_STATUS_9_1);
return version.supports(ESQL_SAMPLE_OPERATOR_STATUS);
}
}
}