honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix incorrectly assign local checkpoint from max_seqno 

Relates #27837
This commit is contained in:
Nhat Nguyen 2017-12-19 11:17:57 -05:00
parent 3b58582059
commit e9a3932dbc
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
core/src/main/java/org/elasticsearch/indices/recovery/PeerRecoveryTargetService.java
View File

@ -356,7 +356,7 @@ public class PeerRecoveryTargetService extends AbstractComponent implements Inde
final long globalCheckpoint = Translog.readGlobalCheckpoint(recoveryTarget.translogLocation()); final long globalCheckpoint = Translog.readGlobalCheckpoint(recoveryTarget.translogLocation());
final Tuple<Long, Long> seqNoStats = recoveryTarget.store().loadSeqNoInfo(); final Tuple<Long, Long> seqNoStats = recoveryTarget.store().loadSeqNoInfo();
long maxSeqNo = seqNoStats.v1(); long maxSeqNo = seqNoStats.v1();
long localCheckpoint = seqNoStats.v1(); long localCheckpoint = seqNoStats.v2();
if (maxSeqNo <= globalCheckpoint) { if (maxSeqNo <= globalCheckpoint) {
assert localCheckpoint <= globalCheckpoint; assert localCheckpoint <= globalCheckpoint;
/* /*