gaoyunhaii commented on a change in pull request #14734:
URL: https://github.com/apache/flink/pull/14734#discussion_r566910553
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java
##########
@@ -183,23 +166,27 @@ public CheckpointStatsSnapshot createSnapshot() {
/**
* Creates a new pending checkpoint tracker.
*
+ * @param tasksToAck Tasks to acknowledge in this checkpoint.
* @param checkpointId ID of the checkpoint.
* @param triggerTimestamp Trigger timestamp of the checkpoint.
* @param props The checkpoint properties.
* @return Tracker for statistics gathering.
*/
PendingCheckpointStats reportPendingCheckpoint(
- long checkpointId, long triggerTimestamp, CheckpointProperties
props) {
+ List<ExecutionVertex> tasksToAck,
Review comment:
The method has been evolved, thus we do not need to modify this for now.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
