Skip to content

Commit 5f828b8

Browse files
Merge branch 'main' into some-counting-cleanup
2 parents 94bd169 + bc0e1d0 commit 5f828b8

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -161,6 +161,7 @@ static TransportVersion def(int id) {
161161
public static final TransportVersion REMOTE_EXCEPTION_8_19 = def(8_841_0_16);
162162
public static final TransportVersion AMAZON_BEDROCK_TASK_SETTINGS_8_19 = def(8_841_0_17);
163163
public static final TransportVersion BATCHED_QUERY_PHASE_VERSION_BACKPORT_8_X = def(8_841_0_19);
164+
public static final TransportVersion SEARCH_INCREMENTAL_TOP_DOCS_NULL_BACKPORT_8_19 = def(8_841_0_20);
164165
public static final TransportVersion INITIAL_ELASTICSEARCH_9_0 = def(9_000_0_00);
165166
public static final TransportVersion REMOVE_SNAPSHOT_FAILURES_90 = def(9_000_0_01);
166167
public static final TransportVersion TRANSPORT_STATS_HANDLING_TIME_REQUIRED_90 = def(9_000_0_02);

server/src/main/java/org/elasticsearch/common/lucene/Lucene.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -386,7 +386,8 @@ public static void writeTotalHits(StreamOutput out, TotalHits totalHits) throws
386386
*/
387387
public static void writeTopDocsIncludingShardIndex(StreamOutput out, TopDocs topDocs) throws IOException {
388388
if (topDocs == null) {
389-
if (out.getTransportVersion().onOrAfter(TransportVersions.SEARCH_INCREMENTAL_TOP_DOCS_NULL)) {
389+
if (out.getTransportVersion().onOrAfter(TransportVersions.SEARCH_INCREMENTAL_TOP_DOCS_NULL)
390+
|| out.getTransportVersion().isPatchFrom(TransportVersions.SEARCH_INCREMENTAL_TOP_DOCS_NULL_BACKPORT_8_19)) {
390391
out.writeByte((byte) -1);
391392
return;
392393
} else {
@@ -434,7 +435,8 @@ public static void writeSortFieldArray(StreamOutput out, SortField[] sortFields)
434435
public static TopDocs readTopDocsIncludingShardIndex(StreamInput in) throws IOException {
435436
byte type = in.readByte();
436437
if (type == -1) {
437-
assert in.getTransportVersion().onOrAfter(TransportVersions.SEARCH_INCREMENTAL_TOP_DOCS_NULL);
438+
assert in.getTransportVersion().onOrAfter(TransportVersions.SEARCH_INCREMENTAL_TOP_DOCS_NULL)
439+
|| in.getTransportVersion().isPatchFrom(TransportVersions.SEARCH_INCREMENTAL_TOP_DOCS_NULL_BACKPORT_8_19);
438440
return null;
439441
} else if (type == 0) {
440442
TotalHits totalHits = readTotalHits(in);

0 commit comments

Comments
 (0)