

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.

# Aktivieren von Checkpointing
<a name="how-zeppelin-checkpoint"></a>

Sie aktivieren Checkpointing mithilfe der Umgebungseinstellungen. Informationen zum Checkpointing finden Sie unter [Fehlertoleranz](https://docs.aws.amazon.com/managed-flink/latest/java/how-fault.html) im [Managed Service für Apache Flink Entwicklerhandbuch](https://docs.aws.amazon.com/managed-flink/latest/java/).

## Stellen Sie das Checkpoint-Intervall ein
<a name="how-zeppelin-checkpoint-interval"></a>

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
<a name="how-zeppelin-checkpoint-type"></a>

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"
)
```