我们公司因为业务的问题,我们不需要生成checkpoint文件。有办法生成checkpoint文件吗,不需要这个恢复机制
|
你好,不设置checkpoint的情况下是不开启这个机制的
sun <[hidden email]> 于2020年1月17日周五 上午10:42写道: > 我们公司因为业务的问题,我们不需要生成checkpoint文件。有办法生成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"<[hidden email]>; 发送时间: 2020年1月17日(星期五) 中午12:10 收件人: "user-zh"<[hidden email]>; 主题: Re: 怎么不使用checkpoint 你好,不设置checkpoint的情况下是不开启这个机制的 sun <[hidden email]> 于2020年1月17日周五 上午10:42写道: > 我们公司因为业务的问题,我们不需要生成checkpoint文件。有办法生成checkpoint文件吗,不需要这个恢复机制 |
Hi
默认情况下,不调用env.enableCheckpoint,也就是不会启用checkpoint的。默认情况下的restart strategy就是NoRestart,也就是不会自动failover的。 祝好 唐云 获取 Outlook for Android<https://aka.ms/ghei36> ________________________________ From: sun <[hidden email]> Sent: Friday, January 17, 2020 1:43:53 PM To: user-zh <[hidden email]> 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"<[hidden email]>; 发送时间: 2020年1月17日(星期五) 中午12:10 收件人: "user-zh"<[hidden email]>; 主题: Re: 怎么不使用checkpoint 你好,不设置checkpoint的情况下是不开启这个机制的 sun <[hidden email]> 于2020年1月17日周五 上午10:42写道: > 我们公司因为业务的问题,我们不需要生成checkpoint文件。有办法生成checkpoint文件吗,不需要这个恢复机制 |
谢谢
------------------ 原始邮件 ------------------ 发件人: "Yun Tang"<[hidden email]>; 发送时间: 2020年1月17日(星期五) 下午2:32 收件人: "[hidden email]"<[hidden email]>; 主题: Re: 回复: 怎么不使用checkpoint Hi 默认情况下,不调用env.enableCheckpoint,也就是不会启用checkpoint的。默认情况下的restart strategy就是NoRestart,也就是不会自动failover的。 祝好 唐云 获取 Outlook for Android<https://aka.ms/ghei36> ________________________________ From: sun <[hidden email]> Sent: Friday, January 17, 2020 1:43:53 PM To: user-zh <[hidden email]> 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); ------------------&nbsp;原始邮件&nbsp;------------------ 发件人:&nbsp;"sysuke Lee"<[hidden email]&gt;; 发送时间:&nbsp;2020年1月17日(星期五) 中午12:10 收件人:&nbsp;"user-zh"<[hidden email]&gt;; 主题:&nbsp;Re: 怎么不使用checkpoint 你好,不设置checkpoint的情况下是不开启这个机制的 sun <[hidden email]&gt; 于2020年1月17日周五 上午10:42写道: &gt; 我们公司因为业务的问题,我们不需要生成checkpoint文件。有办法生成checkpoint文件吗,不需要这个恢复机制 |
Free forum by Nabble | Edit this page |