Backport replica rollback to 6.2 (elastic#28181)

Relates elastic#28181
matarrese · Jan 13, 2018 · 0151c15 · 0151c15
1 parent e44e34f
commit 0151c15
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/.../java/org/elasticsearch/indices/recovery/RecoveryPrepareForTranslogOperationsRequest.java b/.../java/org/elasticsearch/indices/recovery/RecoveryPrepareForTranslogOperationsRequest.java
@@ -50,7 +50,7 @@ class RecoveryPrepareForTranslogOperationsRequest extends TransportRequest {
         if (in.getVersion().before(Version.V_6_0_0_alpha1)) {
             in.readLong(); // maxUnsafeAutoIdTimestamp
         }
-        if (in.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {
+        if (in.getVersion().onOrAfter(Version.V_6_2_0)) {
             createNewTranslog = in.readBoolean();
         } else {
             createNewTranslog = true;
@@ -82,7 +82,7 @@ public void writeTo(StreamOutput out) throws IOException {
         out.writeLong(recoveryId);
         shardId.writeTo(out);
         out.writeVInt(totalTranslogOps);
-        if (out.getVersion().before(Version.V_6_0_0_alpha1)) {
+        if (out.getVersion().before(Version.V_6_2_0)) {
             out.writeLong(IndexRequest.UNSET_AUTO_GENERATED_TIMESTAMP); // maxUnsafeAutoIdTimestamp
         }
         if (out.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {