Le service géré Amazon pour Apache Flink était auparavant connu sous le nom d’Amazon Kinesis Data Analytics pour Apache Flink.
Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.
Vous activez le point de contrôle à l’aide des paramètres d’environnement. Pour obtenir des informations sur le point de contrôle, consultez Tolérance aux pannes dans le guide du développeur du service géré pour Apache Flink.
Définissez l'intervalle entre les points de contrôle
L’exemple de code Scala suivant définit l’intervalle de point de contrôle de votre application à une minute :
// start a checkpoint every 1 minute
stenv.enableCheckpointing(60000)L’exemple de code Python suivant définit l’intervalle de point de contrôle de votre application à une minute :
st_env.get_config().get_configuration().set_string(
"execution.checkpointing.interval", "1min"
)Définissez le type de point de contrôle
L’exemple de code Scala suivant définit le mode point de contrôle de votre application sur EXACTLY_ONCE (valeur par défaut) :
// set mode to exactly-once (this is the default)
stenv.getCheckpointConfig.setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE)L’exemple de code Python suivant définit le mode point de contrôle de votre application sur EXACTLY_ONCE (valeur par défaut) :
st_env.get_config().get_configuration().set_string(
"execution.checkpointing.mode", "EXACTLY_ONCE"
)