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
CUSTOMin order to set theCheckpointingEnabled,CheckpointInterval, orMinPauseBetweenCheckpointsparameters.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 | CUSTOMRequired: Yes
-
- CheckpointingEnabled
-
Describes whether checkpointing is enabled for a Managed Service for Apache Flink application.
Note
If
CheckpointConfiguration.ConfigurationTypeisDEFAULT, the application will use aCheckpointingEnabledvalue 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.ConfigurationTypeisDEFAULT, the application will use aCheckpointIntervalvalue 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.ConfigurationTypeisDEFAULT, the application will use aMinPauseBetweenCheckpointsvalue 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: