

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

# 啟用檢查點
<a name="how-zeppelin-checkpoint"></a>

您可以使用環境設定來啟用檢查點。如需檢查點的相關資訊，請參閱 [Managed Service for Apache Flink 開發人員指南](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"
)
```