本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

# 启用检查点
<a name="how-zeppelin-checkpoint"></a>

您可以使用环境设置启用检查点功能。有关检查点的信息，请参阅[《Managed Service for Apache Flink](https://docs.amazonaws.cn/managed-flink/latest/java/) 开发人员指南》中的[容错能力](https://docs.amazonaws.cn/managed-flink/latest/java/how-fault.html)。

## 设置检查点间隔
<a name="how-zeppelin-checkpoint-interval"></a>

以下 Scala 代码示例将应用程序的检查点间隔设置为一分钟：

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

以下 Python 代码示例将应用程序的检查点间隔设置为一分钟：

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