Flink如何设置部分任务结束后的checkpoint?

提问者:帅平 问题分类:大数据
Flink如何设置部分任务结束后的checkpoint?
1 个回答
少女榨汁机
少女榨汁机
设置部分任务结束后的checkpoint,可以参考如下:
Configuration config = new Configuration();
config.set(ExecutionCheckpointingOptions.ENABLE_CHECKPOINTS_AFTER_TASKS_FINISH, false);
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(config);
发布于:2年前 (2023-08-15) IP属地:四川省
我来回答