PendingCheckpointStats reportPendingCheckpoint ( long checkpointId , long triggerTimestamp , CheckpointProperties props ) { ConcurrentHashMap < JobVertexID , TaskStateStats > taskStateStats = createEmptyTaskStateStatsMap ( ) ; PendingCheckpointStats pending = new PendingCheckpointStats ( checkpointId , triggerTimestamp , props , totalSubtaskCount , taskStateStats , new PendingCheckpointStatsCallback ( ) ) ; statsReadWriteLock . lock ( ) ; try { counts . incrementInProgressCheckpoints ( ) ; history . addInProgressCheckpoint ( pending ) ; dirty = true ; } finally { statsReadWriteLock . unlock ( ) ; } return pending ; }
Creates a new pending checkpoint tracker .