/AWS1/CL_KN2CHECKPOINTCONF¶
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 in the Apache Flink Documentation.
CONSTRUCTOR
¶
IMPORTING¶
Required arguments:¶
iv_configurationtype
TYPE /AWS1/KN2CONFIGURATIONTYPE
/AWS1/KN2CONFIGURATIONTYPE
¶
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.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
Optional arguments:¶
iv_checkpointingenabled
TYPE /AWS1/KN2BOOLEANOBJECT
/AWS1/KN2BOOLEANOBJECT
¶
Describes whether checkpointing is enabled for a Managed Service for Apache Flink application.
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.
iv_checkpointinterval
TYPE /AWS1/KN2CHECKPOINTINTERVAL
/AWS1/KN2CHECKPOINTINTERVAL
¶
Describes the interval in milliseconds between checkpoint operations.
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.
iv_minpausebetweencheckpts
TYPE /AWS1/KN2MINPAUSEBETWEENCHEC00
/AWS1/KN2MINPAUSEBETWEENCHEC00
¶
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 Checkpointing in the Apache Flink Documentation.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.
Queryable Attributes¶
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.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
Accessible with the following methods¶
Method | Description |
---|---|
GET_CONFIGURATIONTYPE() |
Getter for CONFIGURATIONTYPE, with configurable default |
ASK_CONFIGURATIONTYPE() |
Getter for CONFIGURATIONTYPE w/ exceptions if field has no v |
HAS_CONFIGURATIONTYPE() |
Determine if CONFIGURATIONTYPE has a value |
CheckpointingEnabled¶
Describes whether checkpointing is enabled for a Managed Service for Apache Flink application.
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.
Accessible with the following methods¶
Method | Description |
---|---|
GET_CHECKPOINTINGENABLED() |
Getter for CHECKPOINTINGENABLED, with configurable default |
ASK_CHECKPOINTINGENABLED() |
Getter for CHECKPOINTINGENABLED w/ exceptions if field has n |
HAS_CHECKPOINTINGENABLED() |
Determine if CHECKPOINTINGENABLED has a value |
CheckpointInterval¶
Describes the interval in milliseconds between checkpoint operations.
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.
Accessible with the following methods¶
Method | Description |
---|---|
GET_CHECKPOINTINTERVAL() |
Getter for CHECKPOINTINTERVAL, with configurable default |
ASK_CHECKPOINTINTERVAL() |
Getter for CHECKPOINTINTERVAL w/ exceptions if field has no |
HAS_CHECKPOINTINTERVAL() |
Determine if CHECKPOINTINTERVAL has a value |
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 Checkpointing in the Apache Flink Documentation.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.
Accessible with the following methods¶
Method | Description |
---|---|
GET_MINPAUSEBETWEENCHECKPTS() |
Getter for MINPAUSEBETWEENCHECKPOINTS, with configurable def |
ASK_MINPAUSEBETWEENCHECKPTS() |
Getter for MINPAUSEBETWEENCHECKPOINTS w/ exceptions if field |
HAS_MINPAUSEBETWEENCHECKPTS() |
Determine if MINPAUSEBETWEENCHECKPOINTS has a value |