flink流式环境中开启检查点检查点超时时间为1分钟

在Flink流式环境中开启检查点，需要在代码中设置相关参数。具体操作如下：

1. 在创建ExecutionEnvironment或StreamExecutionEnvironment时，设置checkpointing开关为true，即开启检查点机制。

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.enableCheckpointing(60000); // 设置检查点间隔为1分钟

2. 设置检查点超时时间为1分钟。

env.getCheckpointConfig().setCheckpointTimeout(60000);

以上代码可以在流式环境中开启检查点，并设置检查点间隔为1分钟，检查点超时时间也为1分钟。在执行流式任务时，Flink会定期生成检查点，以保证任务的容错性和可恢复性。如果在1分钟内没有生成检查点，就会认为检查点超时，任务会被取消。因此，设置合理的检查点超时时间可以避免任务因检查点超时而被取消。