Amazon Managed Service für Apache Flink war zuvor als Amazon Kinesis Data Analytics für Apache Flink bekannt.

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Checkpointing aktivieren

Sie aktivieren Checkpointing mithilfe der Umgebungseinstellungen. Informationen zum Checkpointing finden Sie unter Fehlertoleranz im Managed Service für Apache Flink Entwicklerhandbuch.

Stellen Sie das Checkpoint-Intervall ein

Im folgenden Scala-Codebeispiel wird das Checkpointing-Intervall Ihrer Anwendung auf eine Minute festgelegt:

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

Im folgenden Python-Codebeispiel wird das Checkpointing-Intervall Ihrer Anwendung auf eine Minute festgelegt:

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

Stellen Sie den Checkpoint-Typ ein

Das folgende Scala-Codebeispiel setzt den Checkpoint-Modus Ihrer Anwendung auf EXACTLY_ONCE (Standard):

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

Das folgende Python-Codebeispiel setzt den Checkpoint-Modus Ihrer Anwendung auf EXACTLY_ONCE (Standard):

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