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属地:四川省
我来回答
您需要 登录 后回答此问题!