使用 Flink Doris Connector设置checkpoint，程序重启不生效

Viewed 57
2.1

doris版本：2.1.5
Flink Doris Connector版本：1.8-24.0.0

使用 Flink Doris Connector 测试 Flink CDC 接入多表或整库功能过程中，
在程序中设置 checkpint的设置，程序每次重启都会先快照全部的表，然后再增量，checkpoint为啥没生效，辛苦大佬帮忙看看，是哪里不对吗？

    //checkpoint配置
    env.enableCheckpointing(10000);
    env.getCheckpointConfig().setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE);
    env.getCheckpointConfig().setCheckpointTimeout(60000);
    env.getCheckpointConfig().setMaxConcurrentCheckpoints(1);
            env.getCheckpointConfig().enableExternalizedCheckpoints(CheckpointConfig.ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION);
    env.setStateBackend(new FsStateBackend("file:///F:\\tmp\\aaa\\aaa\\"));
anan012015
1 Answers