CheckpointConfiguration
Describes an application's checkpointing configuration. Checkpointing is the process of persisting application state for fault
tolerance.
For more information, see
Checkpoints for Fault Tolerance
Contents
- ConfigurationType
-
Describes whether the application uses Managed Service for Apache Flink' default checkpointing behavior. You must set this property to
CUSTOM
in order to set theCheckpointingEnabled
,CheckpointInterval
, orMinPauseBetweenCheckpoints
parameters.Note
If this value is set to
DEFAULT
, the application will use the following values, even if they are set to other values using APIs or application code:-
CheckpointingEnabled: true
-
CheckpointInterval: 60000
-
MinPauseBetweenCheckpoints: 5000
Type: String
Valid Values:
DEFAULT | CUSTOM
Required: Yes
-
- CheckpointingEnabled
-
Describes whether checkpointing is enabled for a Managed Service for Apache Flink application.
Note
If
CheckpointConfiguration.ConfigurationType
isDEFAULT
, the application will use aCheckpointingEnabled
value oftrue
, even if this value is set to another value using this API or in application code.Type: Boolean
Required: No
- CheckpointInterval
-
Describes the interval in milliseconds between checkpoint operations.
Note
If
CheckpointConfiguration.ConfigurationType
isDEFAULT
, the application will use aCheckpointInterval
value of 60000, even if this value is set to another value using this API or in application code.Type: Long
Valid Range: Minimum value of 1.
Required: No
- MinPauseBetweenCheckpoints
-
Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start. If a checkpoint operation takes longer than the
CheckpointInterval
, the application otherwise performs continual checkpoint operations. For more information, see Tuning Checkpointingin the Apache Flink Documentation . Note
If
CheckpointConfiguration.ConfigurationType
isDEFAULT
, the application will use aMinPauseBetweenCheckpoints
value of 5000, even if this value is set using this API or in application code.Type: Long
Valid Range: Minimum value of 0.
Required: No
See Also
For more information about using this API in one of the language-specific AWS SDKs, see the following: