Skip to content

Commit 03d83d3

Browse files
committed
feedback
1 parent bb682e1 commit 03d83d3

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

x-pack/plugin/transform/src/main/java/org/elasticsearch/xpack/transform/action/TransportGetCheckpointNodeAction.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,7 @@ protected static void getGlobalCheckpoints(
9696
Arrays.fill(seqNumbers, SequenceNumbers.UNASSIGNED_SEQ_NO);
9797
return seqNumbers;
9898
});
99-
checkpointsByIndexOfThisNode.get(shardId.getIndexName())[shardId.getId()] = indexShard.seqNoStats().getGlobalCheckpoint();
99+
checkpointsByIndexOfThisNode.get(shardId.getIndexName())[shardId.getId()] = indexShard.getLastKnownGlobalCheckpoint();
100100
++numProcessedShards;
101101
} catch (Exception e) {
102102
logger.atDebug()

0 commit comments

Comments
 (0)