Il servizio gestito da Amazon per Apache Flink era precedentemente noto come Analisi dei dati Amazon Kinesis per Apache Flink.

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Abilita il checkpointing

È possibile abilitare la creazione di checkpoint utilizzando le impostazioni dell'ambiente. Per informazioni sulla creazione di checkpoint, consulta Tolleranza agli errori nella Guida per gli sviluppatori del servizio gestito per Apache Flink.

Imposta l'intervallo di checkpoint

Il seguente esempio di codice Scala imposta l'intervallo di checkpoint dell'applicazione su un minuto:

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

Il seguente esempio di codice Python imposta l'intervallo di checkpoint dell'applicazione su un minuto:

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

Imposta il tipo di checkpoint

Il seguente esempio di codice Scala imposta la modalità di checkpoint dell'applicazione su EXACTLY_ONCE (impostazione predefinita):

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

Il seguente esempio di codice Python imposta la modalità di checkpoint dell'applicazione su EXACTLY_ONCE (impostazione predefinita):

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