启用检查点 - Managed Service for Apache Flink
设置检查点间隔设置检查点类型

适用于 Apache Flink 的亚马逊托管服务（亚马逊 MSF）以前被称为适用于 Apache Flink 的亚马逊 Kinesis Data Analytics。

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

启用检查点

您可以使用环境设置启用检查点功能。有关检查点的信息，请参阅《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"
)