Amazon Managed Service para Apache Flink Amazon (Amazon MSF) se denominaba anteriormente Amazon Kinesis Data Analytics para Apache Flink.

Habilitación de puntos de comprobación

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"
)