Package | Description |
---|---|
org.apache.flink.runtime.checkpoint.decline |
Modifier and Type | Class and Description |
---|---|
class |
AlignmentLimitExceededException
Exception indicating that a checkpoint was declined because too many bytes were
buffered in the alignment phase.
|
class |
CheckpointDeclineOnCancellationBarrierException
Exception indicating that a checkpoint was declined because a cancellation
barrier was received.
|
class |
CheckpointDeclineSubsumedException
Exception indicating that a checkpoint was declined because a newer checkpoint
barrier was received on an input before the pending checkpoint's barrier.
|
class |
CheckpointDeclineTaskNotCheckpointingException
Exception indicating that a checkpoint was declined because a task does not support
checkpointing.
|
class |
CheckpointDeclineTaskNotReadyException
Exception indicating that a checkpoint was declined because a task was not
ready to perform a checkpoint.
|
class |
InputEndOfStreamException
Exception indicating that a checkpoint was declined because one of the input
stream reached its end before the alignment was complete.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.