org.apache.flink.runtime.checkpoint

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

Enum Constants

Enum Constant and Description
CHANNEL_STATE_SHARED_STREAM_EXCEPTION
CHECKPOINT_ASYNC_EXCEPTION
CHECKPOINT_COORDINATOR_SHUTDOWN
CHECKPOINT_COORDINATOR_SUSPEND
CHECKPOINT_DECLINED
CHECKPOINT_DECLINED_INPUT_END_OF_STREAM
CHECKPOINT_DECLINED_ON_CANCELLATION_BARRIER
CHECKPOINT_DECLINED_SUBSUMED
CHECKPOINT_DECLINED_TASK_CLOSING
CHECKPOINT_DECLINED_TASK_NOT_READY
CHECKPOINT_EXPIRED
CHECKPOINT_SUBSUMED
FINALIZE_CHECKPOINT_FAILURE
IO_EXCEPTION
JOB_FAILOVER_REGION
MINIMUM_TIME_BETWEEN_CHECKPOINTS
NOT_ALL_REQUIRED_TASKS_RUNNING
PERIODIC_SCHEDULER_SHUTDOWN
TASK_CHECKPOINT_FAILURE
TASK_FAILURE
TOO_MANY_CHECKPOINT_REQUESTS
TRIGGER_CHECKPOINT_FAILURE
UNKNOWN_TASK_CHECKPOINT_NOTIFICATION_FAILURE

Method Summary

Modifier and Type	Method and 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.

Methods inherited from class java.lang.Enum

clone, compareTo, equals, finalize, getDeclaringClass, hashCode, name, ordinal, toString, valueOf

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

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

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 name

NullPointerException - 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.