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

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

启用检查点操作

您可以使用环境设置启用检查点。有关检查点操作的信息，请参阅容错能力中的Kinesis Data Analytics 开发者指南.

设置检查点间隔

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

设置检查点类型

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