flink中开启检查点检查点超时时间为1分钟

在Flink中开启检查点需要以下步骤：

在Flink配置文件中设置checkpointing.enable参数为true，开启检查点功能。
设置checkpointing.interval参数为检查点的间隔时间，例如：checkpointing.interval=10000表示每10秒钟进行一次检查点。
设置checkpointing.timeout参数为检查点的超时时间，例如：checkpointing.timeout=60000表示检查点超时时间为1分钟。
在程序中实现CheckpointedFunction接口，重写snapshotState和restoreState方法，用于保存和恢复状态。

以下是示例代码：

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.enableCheckpointing(10000); // 每10秒钟进行一次检查点
env.getCheckpointConfig().setCheckpointTimeout(60000); // 检查点超时时间为1分钟

DataStreamSource<String> source = env.socketTextStream("localhost", 9999);

SingleOutputStreamOperator<String> result = source.map(new MapFunction<String, String>() {
    private static final long serialVersionUID = 1L;

    @Override
    public String map(String value) throws Exception {
        // 处理数据逻辑
        return value;
    }
}).keyBy(new KeySelector<String, String>() {
    private static final long serialVersionUID = 1L;

    @Override
    public String getKey(String value) throws Exception {
        // 设置key
        return value;
    }
}).map(new CheckpointedFunction<String, String>() {
    private static final long serialVersionUID = 1L;
    private ListState<String> state;

    @Override
    public void snapshotState(FunctionSnapshotContext context) throws Exception {
        // 保存状态
        state.clear();
        state.addAll(list);
    }

    @Override
    public void initializeState(FunctionInitializationContext context) throws Exception {
        // 初始化状态
        ListStateDescriptor<String> descriptor = new ListStateDescriptor<>("state", String.class);
        state = context.getOperatorStateStore().getListState(descriptor);
        if (context.isRestored()) {
            for (String value : state.get()) {
                // 恢复状态
                list.add(value);
            }
        }
    }

    @Override
    public String map(String value) throws Exception {
        // 处理数据逻辑
        return value;
    }
});

result.print();
env.execute("Flink Checkpoint Demo");
``