Amazon Managed Service para Apache Flink Amazon se denominaba anteriormente Amazon Kinesis Data Analytics para Apache Flink.
Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.
Habilitar los puntos de control
Los puntos de control se activan mediante la configuración del entorno. Para obtener información sobre los puntos de control, consulte la guía para desarrolladores de Fault Tolerance en Managed Service para Apache Flink.
Establecimiento del intervalo de puntos de control
El siguiente ejemplo de código de Scala establece el intervalo de puntos de control de la aplicación en un minuto:
// start a checkpoint every 1 minute stenv.enableCheckpointing(60000)
El siguiente ejemplo de código de Python establece el intervalo de puntos de control de la aplicación en un minuto:
st_env.get_config().get_configuration().set_string( "execution.checkpointing.interval", "1min" )
Establecimiento del tipo de punto de control
El siguiente ejemplo de código de Scala establece el modo de punto de control de la aplicación en EXACTLY_ONCE (predeterminado):
// set mode to exactly-once (this is the default) stenv.getCheckpointConfig.setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE)
El siguiente ejemplo de código de Python establece el modo de punto de control de la aplicación en EXACTLY_ONCE (predeterminado):
st_env.get_config().get_configuration().set_string( "execution.checkpointing.mode", "EXACTLY_ONCE" )
