O Amazon Managed Service para Apache Flink (Amazon MSF) era conhecido anteriormente como Amazon Kinesis Data Analytics for Apache Flink.

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Habilitar pontos de verificação

Você ativa o ponto de verificação usando as configurações do ambiente. Para obter informações sobre pontos de verificação, consulte Tolerância a falhas no Guia do desenvolvedor do Managed Service for Apache Flink.

Defina o intervalo de verificação

O exemplo de código Scala a seguir define o intervalo do ponto de verificação do seu aplicativo em um minuto:

// start a checkpoint every 1 minute
stenv.enableCheckpointing(60000)

O exemplo de código Python a seguir define o intervalo do ponto de verificação do seu aplicativo em um minuto:

st_env.get_config().get_configuration().set_string(
    "execution.checkpointing.interval", "1min"
)

Defina o tipo de ponto de verificação

O exemplo de código Scala a seguir define o modo de ponto de verificação do seu aplicativo como EXACTLY_ONCE (o padrão):

// set mode to exactly-once (this is the default)
stenv.getCheckpointConfig.setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE)

O exemplo de código Python a seguir define o modo de ponto de verificação do seu aplicativo como EXACTLY_ONCE (o padrão):

st_env.get_config().get_configuration().set_string(
    "execution.checkpointing.mode", "EXACTLY_ONCE"
)