Flink 检查点配置:设置周期和超时时间
在 Flink 程序中,开启检查点并设置其周期和超时时间可以通过以下代码实现:
// 设置检查点周期为 10 秒
env.enableCheckpointing(10000);
// 设置检查点超时时间为 60 秒
env.getCheckpointConfig().setCheckpointTimeout(60000);
其中,env 是 Flink 的 StreamExecutionEnvironment 对象,用于配置和执行 Flink 程序。enableCheckpointing 方法用于开启 Flink 的检查点机制,参数表示检查点的周期间隔,单位为毫秒。getCheckpointConfig 方法用于获取当前的检查点配置,通过该方法返回的 CheckpointConfig 对象可以设置检查点的相关属性,如检查点超时时间。
原文地址: https://www.cveoy.top/t/topic/olED 著作权归作者所有。请勿转载和采集!