翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

# チェックポイントを有効にする
<a name="how-zeppelin-checkpoint"></a>

環境設定を使ってチェックポイント機能を有効にします。チェックポイント機能の詳細については、「[Apache Flink 用 Managed Service デベロッパーガイド](https://docs.aws.amazon.com/managed-flink/latest/java/)」の「[フォールトトレランス](https://docs.aws.amazon.com/managed-flink/latest/java/how-fault.html)」を参照してください。

## チェックポイント間隔を設定する
<a name="how-zeppelin-checkpoint-interval"></a>

次の Scala コード例では、アプリケーションのチェックポイント間隔を 1 分に設定しています。

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

次の Python コード例では、アプリケーションのチェックポイント間隔を 1 分に設定しています。

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

## チェックポイントタイプを設定する
<a name="how-zeppelin-checkpoint-type"></a>

次の Scala コードの例では、アプリケーションのチェックポイントモードを `EXACTLY_ONCE` (デフォルト) に設定しています。

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

次の Python コードの例では、アプリケーションのチェックポイントモードを `EXACTLY_ONCE` (デフォルト) に設定しています。

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