Skip to content

Commit 0151c15

Browse files
committed
Backport replica rollback to 6.2 (elastic#28181)
Relates elastic#28181
1 parent e44e34f commit 0151c15

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ class RecoveryPrepareForTranslogOperationsRequest extends TransportRequest {
5050
if (in.getVersion().before(Version.V_6_0_0_alpha1)) {
5151
in.readLong(); // maxUnsafeAutoIdTimestamp
5252
}
53-
if (in.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {
53+
if (in.getVersion().onOrAfter(Version.V_6_2_0)) {
5454
createNewTranslog = in.readBoolean();
5555
} else {
5656
createNewTranslog = true;
@@ -82,7 +82,7 @@ public void writeTo(StreamOutput out) throws IOException {
8282
out.writeLong(recoveryId);
8383
shardId.writeTo(out);
8484
out.writeVInt(totalTranslogOps);
85-
if (out.getVersion().before(Version.V_6_0_0_alpha1)) {
85+
if (out.getVersion().before(Version.V_6_2_0)) {
8686
out.writeLong(IndexRequest.UNSET_AUTO_GENERATED_TIMESTAMP); // maxUnsafeAutoIdTimestamp
8787
}
8888
if (out.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {

0 commit comments

Comments
 (0)