Flink 数据偶尔数据积压导致checkpoint失败

一、问题描述

Flink 程序测试成功，运行一段时间后，数据偶尔数据积压导致checkpoint失败

二、问题原因

可能原因，内存磁盘等承载能力小，数据写入延迟

三、解决方式（暂时）

1.增加checkpoint创建时长，减少写入次数（.enableCheckpointing）
2.增加允许失败次数（.setTolerableCheckpointFailureNumber）

env.setStateBackend(new FsStateBackend(FSSTATEBACKEND));
        env.enableCheckpointing(10000);// 每 ** ms 开始一次 checkpoint
        env.getCheckpointConfig().setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE);// 设置模式为精确一次
        env.getCheckpointConfig().setCheckpointTimeout(100000);// Checkpoint 必须在** ms内完成，否则就会被抛弃
        env.getCheckpointConfig().setMaxConcurrentCheckpoints(2);// 同一时间只允许一个 checkpoint 进行
        env.getCheckpointConfig().setMinPauseBetweenCheckpoints(3000);// 确认 checkpoints 之间的时间会进行 ** ms
        env.getCheckpointConfig().setTolerableCheckpointFailureNumber(5);
        env.setRestartStrategy(RestartStrategies.fixedDelayRestart(3, Time.of(10,TimeUnit.SECONDS)));//重启策略：重启3次，间隔10s