Hi 默认情况下,不调用env.enableCheckpoint,也就是不会启用checkpoint的。默认情况下的restart strategy就是NoRestart,也就是不会自动failover的。
祝好 唐云 获取 Outlook for Android<https://aka.ms/ghei36> ________________________________ From: sun <[email protected]> Sent: Friday, January 17, 2020 1:43:53 PM To: user-zh <[email protected]> Subject: 回复: 怎么不使用checkpoint 是不是不要以下几行代码就是不开启这个机制的 env.enableCheckpointing(CommonConstants.CHECK_POINTING); env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime); env.setParallelism(CommonConstants.PARALLELISM_NUMBER); //作业失败后不重启 env.setRestartStrategy(RestartStrategies.noRestart()); //如果在此之前未完成,则中止正在执行的检查点的时间 默认 10 分钟 env.getCheckpointConfig().setCheckpointTimeout(CommonConstants.CHECK_POINT_TIME_OUT); //如果设置为true,任务将在检查点错误时失败 env.getCheckpointConfig().setFailOnCheckpointingErrors(CommonConstants.FAIL_ON_CHECK_POINT); env.getCheckpointConfig().setMaxConcurrentCheckpoints(CommonConstants.MAX_CHECK_POINTS); env.getCheckpointConfig().setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE); ------------------ 原始邮件 ------------------ 发件人: "sysuke Lee"<[email protected]>; 发送时间: 2020年1月17日(星期五) 中午12:10 收件人: "user-zh"<[email protected]>; 主题: Re: 怎么不使用checkpoint 你好,不设置checkpoint的情况下是不开启这个机制的 sun <[email protected]> 于2020年1月17日周五 上午10:42写道: > 我们公司因为业务的问题,我们不需要生成checkpoint文件。有办法生成checkpoint文件吗,不需要这个恢复机制
