flink中每隔 1000 ms 进行启动一个检查点【设置 checkpoint 的周期】

在Flink中设置checkpoint周期可以通过以下方式实现：

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

//设置checkpoint间隔时间为1000ms
env.enableCheckpointing(1000);

//设置checkpoint模式为exactly-once
env.getCheckpointConfig().setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE);

其中，enableCheckpointing()方法用于设置checkpoint的间隔时间，单位为毫秒。getCheckpointConfig().setCheckpointingMode()方法用于设置checkpoint的模式，常见的有exactly-once、at-least-once和at-most-once三种模式。在本例中，设置为exactly-once模式。

这样，Flink就会每隔1000ms启动一个checkpoint，并在checkpoint完成后保证数据的exactly-once语义