ID Status Acknowledged Trigger Time Latest Acknowledgement Failure Time End to End Duration State Size Buffered During Alignment Discarded Path Failure Message
{{ checkpoint['id'] }} In progress savepoint Completed savepoint Failed savepoint {{ checkpoint['num_acknowledged_subtasks'] }}/{{ checkpoint['num_subtasks'] }} ({{ checkpoint['num_acknowledged_subtasks']/checkpoint['num_subtasks'] | percentage }}) {{ checkpoint['trigger_timestamp'] | amDateFormat:'H:mm:ss' }} {{ checkpoint['latest_ack_timestamp'] | amDateFormat:'H:mm:ss' }} n/a {{ checkpoint['failure_timestamp'] | amDateFormat:'H:mm:ss' }} {{ checkpoint['end_to_end_duration'] | humanizeDuration }} n/a {{ checkpoint['state_size'] | humanizeBytes }} {{ checkpoint['alignment_buffered'] | humanizeBytes }} YesNo {{ checkpoint['external_path'] }} {{ checkpoint['failure_message'] }} n/a

Operators

Name Acknowledged Latest Acknowledgment End to End Duration State Size Buffered During Alignment
{{ v.name | humanizeText }} {{ checkpoint['tasks'][v.id]['num_acknowledged_subtasks'] }}/{{ checkpoint['tasks'][v.id]['num_subtasks'] }} ({{ checkpoint['tasks'][v.id]['num_acknowledged_subtasks']/checkpoint['tasks'][v.id]['num_subtasks'] | percentage }}) {{ checkpoint['tasks'][v.id]['latest_ack_timestamp'] | amDateFormat:'H:mm:ss' }} n/a {{ checkpoint['tasks'][v.id]['end_to_end_duration'] | humanizeDuration }} n/a {{ checkpoint['tasks'][v.id]['state_size'] | humanizeBytes }} {{ checkpoint['tasks'][v.id]['alignment_buffered'] | humanizeBytes }}
End to End Duration State Size Checkpoint Duration (Sync) Checkpoint Duration (Async) Alignment Buffered Alignment Duration
Minimum {{ subtaskDetails[v.id]['summary']['end_to_end_duration']['min'] | humanizeDuration }} {{ subtaskDetails[v.id]['summary']['state_size']['min'] | humanizeBytes }} {{ subtaskDetails[v.id]['summary']['checkpoint_duration']['sync']['min'] | humanizeDuration }} {{ subtaskDetails[v.id]['summary']['checkpoint_duration']['async']['min'] | humanizeDuration }} {{ subtaskDetails[v.id]['summary']['alignment']['buffered']['min'] | humanizeBytes }} {{ subtaskDetails[v.id]['summary']['alignment']['duration']['min'] | humanizeDuration }}
Average {{ subtaskDetails[v.id]['summary']['end_to_end_duration']['avg'] | humanizeDuration }} {{ subtaskDetails[v.id]['summary']['state_size']['avg'] | humanizeBytes }} {{ subtaskDetails[v.id]['summary']['checkpoint_duration']['sync']['avg'] | humanizeDuration }} {{ subtaskDetails[v.id]['summary']['checkpoint_duration']['async']['avg'] | humanizeDuration }} {{ subtaskDetails[v.id]['summary']['alignment']['buffered']['avg'] | humanizeBytes }} {{ subtaskDetails[v.id]['summary']['alignment']['duration']['avg'] | humanizeDuration }}
Maximum {{ subtaskDetails[v.id]['summary']['end_to_end_duration']['max'] | humanizeDuration }} {{ subtaskDetails[v.id]['summary']['state_size']['max'] | humanizeBytes }} {{ subtaskDetails[v.id]['summary']['checkpoint_duration']['sync']['max'] | humanizeDuration }} {{ subtaskDetails[v.id]['summary']['checkpoint_duration']['async']['max'] | humanizeDuration }} {{ subtaskDetails[v.id]['summary']['alignment']['buffered']['max'] | humanizeBytes }} {{ subtaskDetails[v.id]['summary']['alignment']['duration']['max'] | humanizeDuration }}
Subtask # Acknowledgement Time End to End Duration State Size Checkpoint Duration (Sync) Checkpoint Duration (Async) Alignment Buffered Alignment Duration
{{ subtask['index'] + 1 }} {{ subtask['ack_timestamp'] | amDateFormat:'H:mm:ss' }} {{ subtask['end_to_end_duration'] | humanizeDuration }} {{ subtask['state_size'] | humanizeBytes }} {{ subtask['checkpoint']['sync'] | humanizeDuration }} {{ subtask['checkpoint']['async'] | humanizeDuration }} {{ subtask['alignment']['buffered'] | humanizeBytes}} {{ subtask['alignment']['duration'] | humanizeDuration }} n/a