Initialize

jasontedor · jasontedor · commit 4d9fa1acddfe · 2019-02-05T14:47:03.000-05:00
diff --git a/server/src/main/java/org/elasticsearch/indices/recovery/RecoveryTranslogOperationsRequest.java b/server/src/main/java/org/elasticsearch/indices/recovery/RecoveryTranslogOperationsRequest.java
@@ -23,6 +23,7 @@
 import org.elasticsearch.action.index.IndexRequest;
 import org.elasticsearch.common.io.stream.StreamInput;
 import org.elasticsearch.common.io.stream.StreamOutput;
+import org.elasticsearch.index.seqno.RetentionLease;
 import org.elasticsearch.index.seqno.RetentionLeases;
 import org.elasticsearch.index.seqno.SequenceNumbers;
 import org.elasticsearch.index.shard.ShardId;
@@ -110,6 +111,8 @@ public void readFrom(StreamInput in) throws IOException {
         }
         if (in.getVersion().onOrAfter(Version.V_7_0_0)) {
             retentionLeases = new RetentionLeases(in);
+        } else {
+            retentionLeases = RetentionLeases.EMPTY;
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -23,6 +23,7 @@`
`23`	`23`	`import org.elasticsearch.action.index.IndexRequest;`
`24`	`24`	`import org.elasticsearch.common.io.stream.StreamInput;`
`25`	`25`	`import org.elasticsearch.common.io.stream.StreamOutput;`
	`26`	`+import org.elasticsearch.index.seqno.RetentionLease;`
`26`	`27`	`import org.elasticsearch.index.seqno.RetentionLeases;`
`27`	`28`	`import org.elasticsearch.index.seqno.SequenceNumbers;`
`28`	`29`	`import org.elasticsearch.index.shard.ShardId;`
`@@ -110,6 +111,8 @@ public void readFrom(StreamInput in) throws IOException {`
`110`	`111`	`}`
`111`	`112`	`if (in.getVersion().onOrAfter(Version.V_7_0_0)) {`
`112`	`113`	`retentionLeases = new RetentionLeases(in);`
	`114`	`+ } else {`
	`115`	`+ retentionLeases = RetentionLeases.EMPTY;`
`113`	`116`	`}`
`114`	`117`	`}`
`115`	`118`