Skip to content

Commit 85f4e44

Browse files
Transport version backport
1 parent fc4edd8 commit 85f4e44

File tree

5 files changed

+8
-19
lines changed

5 files changed

+8
-19
lines changed

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -330,7 +330,6 @@ static TransportVersion def(int id) {
330330
public static final TransportVersion MAPPINGS_IN_DATA_STREAMS = def(9_112_0_00);
331331
public static final TransportVersion ESQL_SPLIT_ON_BIG_VALUES_9_1 = def(9_112_0_01);
332332
public static final TransportVersion ESQL_FIXED_INDEX_LIKE_9_1 = def(9_112_0_02);
333-
public static final TransportVersion ESQL_FIXED_INDEX_LIKE = def(9_119_0_00);
334333

335334
/*
336335
* STOP! READ THIS FIRST! No, really,

server/src/main/java/org/elasticsearch/index/query/WildcardQueryBuilder.java

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,6 @@
3232
import java.util.Objects;
3333

3434
import static org.elasticsearch.TransportVersions.ESQL_FIXED_INDEX_LIKE_8_19;
35-
import static org.elasticsearch.TransportVersions.ESQL_FIXED_INDEX_LIKE_9_1;
3635

3736
/**
3837
* Implements the wildcard search query. Supported wildcards are {@code *}, which
@@ -107,9 +106,8 @@ public WildcardQueryBuilder(StreamInput in) throws IOException {
107106
value = in.readString();
108107
rewrite = in.readOptionalString();
109108
caseInsensitive = in.readBoolean();
110-
if (in.getTransportVersion().onOrAfter(TransportVersions.ESQL_FIXED_INDEX_LIKE)
111-
|| in.getTransportVersion().isPatchFrom(ESQL_FIXED_INDEX_LIKE_8_19)
112-
|| in.getTransportVersion().isPatchFrom(ESQL_FIXED_INDEX_LIKE_9_1)) {
109+
if (in.getTransportVersion().onOrAfter(TransportVersions.ESQL_FIXED_INDEX_LIKE_9_1)
110+
|| in.getTransportVersion().isPatchFrom(ESQL_FIXED_INDEX_LIKE_8_19)) {
113111
forceStringMatch = in.readBoolean();
114112
} else {
115113
forceStringMatch = false;
@@ -122,9 +120,8 @@ protected void doWriteTo(StreamOutput out) throws IOException {
122120
out.writeString(value);
123121
out.writeOptionalString(rewrite);
124122
out.writeBoolean(caseInsensitive);
125-
if (out.getTransportVersion().onOrAfter(TransportVersions.ESQL_FIXED_INDEX_LIKE)
126-
|| out.getTransportVersion().isPatchFrom(ESQL_FIXED_INDEX_LIKE_8_19)
127-
|| out.getTransportVersion().isPatchFrom(ESQL_FIXED_INDEX_LIKE_9_1)) {
123+
if (out.getTransportVersion().onOrAfter(TransportVersions.ESQL_FIXED_INDEX_LIKE_9_1)
124+
|| out.getTransportVersion().isPatchFrom(ESQL_FIXED_INDEX_LIKE_8_19)) {
128125
out.writeBoolean(forceStringMatch);
129126
}
130127
}

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/expression/function/scalar/string/regex/WildcardLikeList.java

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@
1111
import org.apache.lucene.util.automaton.Automaton;
1212
import org.apache.lucene.util.automaton.CharacterRunAutomaton;
1313
import org.elasticsearch.TransportVersion;
14-
import org.elasticsearch.TransportVersions;
1514
import org.elasticsearch.common.io.stream.NamedWriteableRegistry;
1615
import org.elasticsearch.common.io.stream.StreamInput;
1716
import org.elasticsearch.common.io.stream.StreamOutput;
@@ -148,10 +147,7 @@ public Query asQuery(LucenePushdownPredicates pushdownPredicates, TranslatorHand
148147
}
149148

150149
private boolean supportsPushdown(TransportVersion version) {
151-
return version == null
152-
|| version.onOrAfter(TransportVersions.ESQL_FIXED_INDEX_LIKE)
153-
|| version.isPatchFrom(ESQL_FIXED_INDEX_LIKE_8_19)
154-
|| version.isPatchFrom(ESQL_FIXED_INDEX_LIKE_9_1);
150+
return version == null || version.onOrAfter(ESQL_FIXED_INDEX_LIKE_9_1) || version.isPatchFrom(ESQL_FIXED_INDEX_LIKE_8_19);
155151
}
156152

157153
@Override

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/io/stream/PlanStreamWrapperQueryBuilder.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -53,14 +53,13 @@ public void writeTo(StreamOutput out) throws IOException {
5353

5454
@Override
5555
public TransportVersion getMinimalSupportedVersion() {
56-
return TransportVersions.ESQL_FIXED_INDEX_LIKE;
56+
return TransportVersions.ESQL_FIXED_INDEX_LIKE_9_1;
5757
}
5858

5959
@Override
6060
public boolean supportsVersion(TransportVersion version) {
61-
return version.onOrAfter(TransportVersions.ESQL_FIXED_INDEX_LIKE)
62-
|| version.isPatchFrom(TransportVersions.ESQL_FIXED_INDEX_LIKE_8_19)
63-
|| version.isPatchFrom(TransportVersions.ESQL_FIXED_INDEX_LIKE_9_1);
61+
return version.onOrAfter(TransportVersions.ESQL_FIXED_INDEX_LIKE_9_1)
62+
|| version.isPatchFrom(TransportVersions.ESQL_FIXED_INDEX_LIKE_8_19);
6463
}
6564

6665
@Override

x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/optimizer/LocalPhysicalPlanOptimizerTests.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,6 @@
9191
import org.elasticsearch.xpack.esql.plan.physical.TimeSeriesSourceExec;
9292
import org.elasticsearch.xpack.esql.plan.physical.TopNExec;
9393
import org.elasticsearch.xpack.esql.planner.FilterTests;
94-
import org.elasticsearch.xpack.esql.plugin.EsqlFlags;
9594
import org.elasticsearch.xpack.esql.plugin.QueryPragmas;
9695
import org.elasticsearch.xpack.esql.querydsl.query.SingleValueQuery;
9796
import org.elasticsearch.xpack.esql.rule.Rule;
@@ -2057,7 +2056,6 @@ public void testToDateNanosPushDown() {
20572056
assertThat(expected.toString(), is(esQuery.query().toString()));
20582057
}
20592058

2060-
20612059
private boolean isMultiTypeEsField(Expression e) {
20622060
return e instanceof FieldAttribute fa && fa.field() instanceof MultiTypeEsField;
20632061
}

0 commit comments

Comments
 (0)