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