Skip to content

Commit 76bd65e

Browse files
moschethecoop
andauthored
Re-remove min compatible version from SearchRequest (#123859) (#125093)
Re-apply transport changes from #114713 (cherry picked from commit 30a37c3) # Conflicts: # server/src/main/java/org/elasticsearch/TransportVersions.java Co-authored-by: Simon Cooper <simon.cooper@elastic.co>
1 parent a5310a8 commit 76bd65e

File tree

2 files changed

+4
-7
lines changed

2 files changed

+4
-7
lines changed

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

+1
Original file line numberDiff line numberDiff line change
@@ -186,6 +186,7 @@ static TransportVersion def(int id) {
186186
public static final TransportVersion REMOVE_ALL_APPLICABLE_SELECTOR_9_0 = def(9_000_0_05);
187187
public static final TransportVersion BYTE_SIZE_VALUE_ALWAYS_USES_BYTES_90 = def(9_000_0_06);
188188
public static final TransportVersion RETRY_ILM_ASYNC_ACTION_REQUIRE_ERROR_90 = def(9_000_0_07);
189+
public static final TransportVersion RE_REMOVE_MIN_COMPATIBLE_SHARD_NODE_90 = def(9_000_0_08);
189190

190191
/*
191192
* STOP! READ THIS FIRST! No, really,

server/src/main/java/org/elasticsearch/action/search/SearchRequest.java

+3-7
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@
2020
import org.elasticsearch.common.io.stream.StreamOutput;
2121
import org.elasticsearch.core.Nullable;
2222
import org.elasticsearch.core.TimeValue;
23-
import org.elasticsearch.core.UpdateForV9;
2423
import org.elasticsearch.index.mapper.SourceLoader;
2524
import org.elasticsearch.index.query.QueryRewriteContext;
2625
import org.elasticsearch.index.query.Rewriteable;
@@ -254,10 +253,8 @@ public SearchRequest(StreamInput in) throws IOException {
254253
finalReduce = true;
255254
}
256255
ccsMinimizeRoundtrips = in.readBoolean();
257-
if ((in.getTransportVersion().before(TransportVersions.REMOVE_MIN_COMPATIBLE_SHARD_NODE)
258-
|| in.getTransportVersion().onOrAfter(TransportVersions.REVERT_REMOVE_MIN_COMPATIBLE_SHARD_NODE)) && in.readBoolean()) {
259-
@UpdateForV9(owner = UpdateForV9.Owner.CORE_INFRA) // this can be removed (again) when the v9 transport version can diverge
260-
Version v = Version.readVersion(in); // and drop on the floor
256+
if (in.getTransportVersion().before(TransportVersions.RE_REMOVE_MIN_COMPATIBLE_SHARD_NODE_90) && in.readBoolean()) {
257+
Version.readVersion(in); // and drop on the floor
261258
}
262259
waitForCheckpoints = in.readMap(StreamInput::readLongArray);
263260
waitForCheckpointsTimeout = in.readTimeValue();
@@ -293,8 +290,7 @@ public void writeTo(StreamOutput out) throws IOException {
293290
out.writeBoolean(finalReduce);
294291
}
295292
out.writeBoolean(ccsMinimizeRoundtrips);
296-
if (out.getTransportVersion().before(TransportVersions.REMOVE_MIN_COMPATIBLE_SHARD_NODE)
297-
|| out.getTransportVersion().onOrAfter(TransportVersions.REVERT_REMOVE_MIN_COMPATIBLE_SHARD_NODE)) {
293+
if (out.getTransportVersion().before(TransportVersions.RE_REMOVE_MIN_COMPATIBLE_SHARD_NODE_90)) {
298294
out.writeBoolean(false);
299295
}
300296
out.writeMap(waitForCheckpoints, StreamOutput::writeLongArray);

0 commit comments

Comments
 (0)