Skip to content

Commit cd2333c

Browse files
committed
bug
1 parent e053aa0 commit cd2333c

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

server/src/main/java/org/elasticsearch/action/support/replication/TransportReplicationAction.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -696,7 +696,7 @@ public void onResponse(Releasable releasable) {
696696
replicaResult.runPostReplicaActions(new ReplicaPostReplicationActionsListener() {
697697
@Override
698698
public void onResponse(long globalCheckpoint, long localCheckpoint) {
699-
final ReplicaResponse response = new ReplicaResponse(globalCheckpoint, localCheckpoint);
699+
final ReplicaResponse response = new ReplicaResponse(localCheckpoint, globalCheckpoint);
700700
releasable.close(); // release shard operation lock before responding to caller
701701
if (logger.isTraceEnabled()) {
702702
logger.trace(

server/src/main/java/org/elasticsearch/action/support/replication/TransportWriteAction.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -559,6 +559,7 @@ public void onFailure(Exception e) {
559559
if (sync) {
560560
assert pendingOps.get() > 0;
561561
indexShard.syncAfterWrite(location, e -> {
562+
updateCheckpoints();
562563
syncFailure.set(e);
563564
maybeFinish();
564565
});

0 commit comments

Comments
 (0)