本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
启用检查点操作
您可以使用环境设置启用检查点。有关检查点操作的信息,请参阅容错能力中的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" )