|
@@ -477,7 +477,7 @@ public class IndexShard extends AbstractIndexShardComponent implements IndicesCl
|
|
*/
|
|
*/
|
|
getEngine().restoreLocalCheckpointFromTranslog();
|
|
getEngine().restoreLocalCheckpointFromTranslog();
|
|
getEngine().fillSeqNoGaps(newPrimaryTerm);
|
|
getEngine().fillSeqNoGaps(newPrimaryTerm);
|
|
- updateLocalCheckpointForShard(currentRouting.allocationId().getId(),
|
|
|
|
|
|
+ getEngine().seqNoService().updateLocalCheckpointForShard(currentRouting.allocationId().getId(),
|
|
getEngine().seqNoService().getLocalCheckpoint());
|
|
getEngine().seqNoService().getLocalCheckpoint());
|
|
primaryReplicaSyncer.accept(this, new ActionListener<ResyncTask>() {
|
|
primaryReplicaSyncer.accept(this, new ActionListener<ResyncTask>() {
|
|
@Override
|
|
@Override
|
|
@@ -1661,6 +1661,7 @@ public class IndexShard extends AbstractIndexShardComponent implements IndicesCl
|
|
*/
|
|
*/
|
|
public void updateLocalCheckpointForShard(final String allocationId, final long checkpoint) {
|
|
public void updateLocalCheckpointForShard(final String allocationId, final long checkpoint) {
|
|
verifyPrimary();
|
|
verifyPrimary();
|
|
|
|
+ verifyNotClosed();
|
|
getEngine().seqNoService().updateLocalCheckpointForShard(allocationId, checkpoint);
|
|
getEngine().seqNoService().updateLocalCheckpointForShard(allocationId, checkpoint);
|
|
}
|
|
}
|
|
|
|
|