Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

Amazon Managed Service for Apache Flink 之前称为 Amazon Kinesis Data Analytics for Apache Flink。

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

启用检查点功能

您可以使用环境设置启用检查点功能。有关检查点的信息，请参阅《Managed Service for Apache Flink 开发人员指南》中的容错能力。

设置检查点间隔

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

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

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

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

设置检查点类型

以下 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"
)