Class CheckpointStatistics.FailedCheckpointStatistics
- java.lang.Object
-
- org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics
-
- org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics.FailedCheckpointStatistics
-
- All Implemented Interfaces:
ResponseBody
- Enclosing class:
- CheckpointStatistics
public static final class CheckpointStatistics.FailedCheckpointStatistics extends CheckpointStatistics
Statistics for a failed checkpoint.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics
CheckpointStatistics.CompletedCheckpointStatistics, CheckpointStatistics.FailedCheckpointStatistics, CheckpointStatistics.PendingCheckpointStatistics
-
-
Field Summary
Fields Modifier and Type Field Description static String
FIELD_NAME_FAILURE_MESSAGE
static String
FIELD_NAME_FAILURE_TIMESTAMP
-
Fields inherited from class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics
FIELD_NAME_ALIGNMENT_BUFFERED, FIELD_NAME_CHECKPOINT_TYPE, FIELD_NAME_CHECKPOINTED_SIZE, FIELD_NAME_DURATION, FIELD_NAME_ID, FIELD_NAME_IS_SAVEPOINT, FIELD_NAME_LATEST_ACK_TIMESTAMP, FIELD_NAME_NUM_ACK_SUBTASKS, FIELD_NAME_NUM_SUBTASKS, FIELD_NAME_PERSISTED_DATA, FIELD_NAME_PROCESSED_DATA, FIELD_NAME_SAVEPOINT_FORMAT, FIELD_NAME_STATE_SIZE, FIELD_NAME_STATUS, FIELD_NAME_TASKS, FIELD_NAME_TRIGGER_TIMESTAMP
-
-
Constructor Summary
Constructors Constructor Description FailedCheckpointStatistics(long id, CheckpointStatsStatus status, boolean savepoint, String savepointFormat, long triggerTimestamp, long latestAckTimestamp, long checkpointedSize, long stateSize, long duration, long alignmentBuffered, long processedData, long persistedData, int numSubtasks, int numAckSubtasks, org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics.RestAPICheckpointType checkpointType, Map<JobVertexID,TaskCheckpointStatistics> checkpointingStatisticsPerTask, long failureTimestamp, String failureMessage)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object o)
String
getFailureMessage()
long
getFailureTimestamp()
int
hashCode()
-
Methods inherited from class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics
generateCheckpointStatistics, getCheckpointedSize, getCheckpointStatisticsPerTask, getCheckpointType, getDuration, getId, getLatestAckTimestamp, getNumAckSubtasks, getNumSubtasks, getStateSize, getStatus, getTriggerTimestamp, isSavepoint
-
-
-
-
Field Detail
-
FIELD_NAME_FAILURE_TIMESTAMP
public static final String FIELD_NAME_FAILURE_TIMESTAMP
- See Also:
- Constant Field Values
-
FIELD_NAME_FAILURE_MESSAGE
public static final String FIELD_NAME_FAILURE_MESSAGE
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
FailedCheckpointStatistics
public FailedCheckpointStatistics(long id, CheckpointStatsStatus status, boolean savepoint, String savepointFormat, long triggerTimestamp, long latestAckTimestamp, long checkpointedSize, long stateSize, long duration, long alignmentBuffered, long processedData, long persistedData, int numSubtasks, int numAckSubtasks, org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics.RestAPICheckpointType checkpointType, Map<JobVertexID,TaskCheckpointStatistics> checkpointingStatisticsPerTask, long failureTimestamp, @Nullable String failureMessage)
-
-
Method Detail
-
getFailureTimestamp
public long getFailureTimestamp()
-
getFailureMessage
@Nullable public String getFailureMessage()
-
equals
public boolean equals(Object o)
- Overrides:
equals
in classCheckpointStatistics
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classCheckpointStatistics
-
-