Enum CheckpointFailureReason
- java.lang.Object
-
- java.lang.Enum<CheckpointFailureReason>
-
- org.apache.flink.runtime.checkpoint.CheckpointFailureReason
-
- All Implemented Interfaces:
Serializable
,Comparable<CheckpointFailureReason>
public enum CheckpointFailureReason extends Enum<CheckpointFailureReason>
Various reasons why a checkpoint was failure.
-
-
Enum Constant Summary
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
isPreFlight()
String
message()
static CheckpointFailureReason
valueOf(String name)
Returns the enum constant of this type with the specified name.static CheckpointFailureReason[]
values()
Returns an array containing the constants of this enum type, in the order they are declared.
-
-
-
Enum Constant Detail
-
PERIODIC_SCHEDULER_SHUTDOWN
public static final CheckpointFailureReason PERIODIC_SCHEDULER_SHUTDOWN
-
TOO_MANY_CHECKPOINT_REQUESTS
public static final CheckpointFailureReason TOO_MANY_CHECKPOINT_REQUESTS
-
MINIMUM_TIME_BETWEEN_CHECKPOINTS
public static final CheckpointFailureReason MINIMUM_TIME_BETWEEN_CHECKPOINTS
-
NOT_ALL_REQUIRED_TASKS_RUNNING
public static final CheckpointFailureReason NOT_ALL_REQUIRED_TASKS_RUNNING
-
IO_EXCEPTION
public static final CheckpointFailureReason IO_EXCEPTION
-
BLOCKING_OUTPUT_EXIST
public static final CheckpointFailureReason BLOCKING_OUTPUT_EXIST
-
CHECKPOINT_ASYNC_EXCEPTION
public static final CheckpointFailureReason CHECKPOINT_ASYNC_EXCEPTION
-
CHANNEL_STATE_SHARED_STREAM_EXCEPTION
public static final CheckpointFailureReason CHANNEL_STATE_SHARED_STREAM_EXCEPTION
-
CHECKPOINT_EXPIRED
public static final CheckpointFailureReason CHECKPOINT_EXPIRED
-
CHECKPOINT_SUBSUMED
public static final CheckpointFailureReason CHECKPOINT_SUBSUMED
-
CHECKPOINT_DECLINED
public static final CheckpointFailureReason CHECKPOINT_DECLINED
-
CHECKPOINT_DECLINED_TASK_NOT_READY
public static final CheckpointFailureReason CHECKPOINT_DECLINED_TASK_NOT_READY
-
CHECKPOINT_DECLINED_TASK_CLOSING
public static final CheckpointFailureReason CHECKPOINT_DECLINED_TASK_CLOSING
-
CHECKPOINT_DECLINED_SUBSUMED
public static final CheckpointFailureReason CHECKPOINT_DECLINED_SUBSUMED
-
CHECKPOINT_DECLINED_ON_CANCELLATION_BARRIER
public static final CheckpointFailureReason CHECKPOINT_DECLINED_ON_CANCELLATION_BARRIER
-
CHECKPOINT_DECLINED_INPUT_END_OF_STREAM
public static final CheckpointFailureReason CHECKPOINT_DECLINED_INPUT_END_OF_STREAM
-
CHECKPOINT_COORDINATOR_SHUTDOWN
public static final CheckpointFailureReason CHECKPOINT_COORDINATOR_SHUTDOWN
-
CHECKPOINT_COORDINATOR_SUSPEND
public static final CheckpointFailureReason CHECKPOINT_COORDINATOR_SUSPEND
-
JOB_FAILOVER_REGION
public static final CheckpointFailureReason JOB_FAILOVER_REGION
-
TASK_FAILURE
public static final CheckpointFailureReason TASK_FAILURE
-
TASK_CHECKPOINT_FAILURE
public static final CheckpointFailureReason TASK_CHECKPOINT_FAILURE
-
UNKNOWN_TASK_CHECKPOINT_NOTIFICATION_FAILURE
public static final CheckpointFailureReason UNKNOWN_TASK_CHECKPOINT_NOTIFICATION_FAILURE
-
FINALIZE_CHECKPOINT_FAILURE
public static final CheckpointFailureReason FINALIZE_CHECKPOINT_FAILURE
-
TRIGGER_CHECKPOINT_FAILURE
public static final CheckpointFailureReason TRIGGER_CHECKPOINT_FAILURE
-
-
Method Detail
-
values
public static CheckpointFailureReason[] values()
Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows:for (CheckpointFailureReason c : CheckpointFailureReason.values()) System.out.println(c);
- Returns:
- an array containing the constants of this enum type, in the order they are declared
-
valueOf
public static CheckpointFailureReason valueOf(String name)
Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)- Parameters:
name
- the name of the enum constant to be returned.- Returns:
- the enum constant with the specified name
- Throws:
IllegalArgumentException
- if this enum type has no constant with the specified nameNullPointerException
- if the argument is null
-
message
public String message()
-
isPreFlight
public boolean isPreFlight()
- Returns:
- true if this value indicates a failure reason happening before a checkpoint is passed to a job's tasks.
-
-