Skip to content

Commit 570f4a5

Browse files
dnhatnkcm
authored andcommitted
Adjust bwc for recovery request (#33693)
Relates #33693
1 parent ea7bca8 commit 570f4a5

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

server/src/main/java/org/elasticsearch/indices/recovery/RecoveryTranslogOperationsRequest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@ public void readFrom(StreamInput in) throws IOException {
7777
shardId = ShardId.readShardId(in);
7878
operations = Translog.readOperations(in, "recovery");
7979
totalTranslogOps = in.readVInt();
80-
if (in.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {
80+
if (in.getVersion().onOrAfter(Version.V_6_5_0)) {
8181
maxSeenAutoIdTimestampOnPrimary = in.readZLong();
8282
} else {
8383
maxSeenAutoIdTimestampOnPrimary = IndexRequest.UNSET_AUTO_GENERATED_TIMESTAMP;
@@ -91,7 +91,7 @@ public void writeTo(StreamOutput out) throws IOException {
9191
shardId.writeTo(out);
9292
Translog.writeOperations(out, operations);
9393
out.writeVInt(totalTranslogOps);
94-
if (out.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {
94+
if (out.getVersion().onOrAfter(Version.V_6_5_0)) {
9595
out.writeZLong(maxSeenAutoIdTimestampOnPrimary);
9696
}
9797
}

0 commit comments

Comments
 (0)