Anteriormente, o Amazon Managed Service for Apache Flink era conhecido 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á.

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