public class FailedCheckpointStats extends AbstractCheckpointStats
The reported statistics are immutable.
Modifier and Type | Method and Description |
---|---|
long |
getEndToEndDuration()
Returns the end to end duration until the checkpoint failure.
|
String |
getFailureMessage()
Returns the failure message or
null if no cause was provided. |
long |
getFailureTimestamp()
Returns the timestamp when this checkpoint failed.
|
SubtaskStateStats |
getLatestAcknowledgedSubtaskStats()
Returns the latest acknowledged subtask stats or
null if none was acknowledged
yet. |
int |
getNumberOfAcknowledgedSubtasks()
Returns the number of acknowledged subtasks.
|
long |
getStateSize()
Returns the total checkpoint state size over all subtasks.
|
CheckpointStatsStatus |
getStatus()
Returns the status of this checkpoint.
|
getAllTaskStateStats, getCheckpointId, getLatestAckTimestamp, getNumberOfSubtasks, getProperties, getTaskStateStats, getTriggerTimestamp
public CheckpointStatsStatus getStatus()
AbstractCheckpointStats
getStatus
in class AbstractCheckpointStats
public int getNumberOfAcknowledgedSubtasks()
AbstractCheckpointStats
getNumberOfAcknowledgedSubtasks
in class AbstractCheckpointStats
public long getStateSize()
AbstractCheckpointStats
getStateSize
in class AbstractCheckpointStats
@Nullable public SubtaskStateStats getLatestAcknowledgedSubtaskStats()
AbstractCheckpointStats
null
if none was acknowledged
yet.getLatestAcknowledgedSubtaskStats
in class AbstractCheckpointStats
null
public long getEndToEndDuration()
getEndToEndDuration
in class AbstractCheckpointStats
-1
if no subtask was acknowledged yet.public long getFailureTimestamp()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.