Allow to trim all ops above a certain seq# with a term lower than X -…

… fixes on PR elastic#5 Relates to elastic#10708
vladimirdolzhenko · May 4, 2018 · d454a30 · d454a30
1 parent 1e67a8a
commit d454a30
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/server/src/main/java/org/elasticsearch/index/shard/PrimaryReplicaSyncer.java b/server/src/main/java/org/elasticsearch/index/shard/PrimaryReplicaSyncer.java
@@ -84,9 +84,8 @@ public void resync(final IndexShard indexShard, final ActionListener<ResyncTask>
         ActionListener<ResyncTask> resyncListener = null;
         try {
             final long startingSeqNo = indexShard.getGlobalCheckpoint() + 1;
-            final SeqNoStats seqNoStats = indexShard.seqNoStats();
-            final long maxSeqNo = seqNoStats != null ? seqNoStats.getMaxSeqNo() : SequenceNumbers.UNASSIGNED_SEQ_NO;
             Translog.Snapshot snapshot = indexShard.newTranslogSnapshotFromMinSeqNo(startingSeqNo);
+            final long maxSeqNo = indexShard.seqNoStats().getMaxSeqNo();
             resyncListener = new ActionListener<ResyncTask>() {
                 @Override
                 public void onResponse(final ResyncTask resyncTask) {