|
20 | 20 | import org.elasticsearch.common.io.stream.StreamOutput; |
21 | 21 | import org.elasticsearch.core.Nullable; |
22 | 22 | import org.elasticsearch.core.TimeValue; |
23 | | -import org.elasticsearch.core.UpdateForV9; |
24 | 23 | import org.elasticsearch.index.mapper.SourceLoader; |
25 | 24 | import org.elasticsearch.index.query.QueryRewriteContext; |
26 | 25 | import org.elasticsearch.index.query.Rewriteable; |
@@ -254,10 +253,8 @@ public SearchRequest(StreamInput in) throws IOException { |
254 | 253 | finalReduce = true; |
255 | 254 | } |
256 | 255 | 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) && in.readBoolean()) { |
| 257 | + Version.readVersion(in); // and drop on the floor |
261 | 258 | } |
262 | 259 | waitForCheckpoints = in.readMap(StreamInput::readLongArray); |
263 | 260 | waitForCheckpointsTimeout = in.readTimeValue(); |
@@ -293,8 +290,7 @@ public void writeTo(StreamOutput out) throws IOException { |
293 | 290 | out.writeBoolean(finalReduce); |
294 | 291 | } |
295 | 292 | 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)) { |
298 | 294 | out.writeBoolean(false); |
299 | 295 | } |
300 | 296 | out.writeMap(waitForCheckpoints, StreamOutput::writeLongArray); |
|
0 commit comments