Mecanismo de Tolerância a Falhas no Flink: Savepoints e Checkpoints
Configuração Comum de Checkpoints no Flink
// Configuração de checkpoints
ExecutionEnvironment ambienteExecucao = ...;
ambienteExecucao.enableCheckpointing(180000); // Habilita checkpoint a cada 180000ms
CheckpointConfig configuracaoCheckpoint = ambienteExecucao.getCheckpointConfig();
configuracaoCheckpoint.setMinPauseBetweenCheckpoints(50000 ...
Publicado em 6-1 20:21 por Thomas