怎么不使用checkpoint

classic Classic list List threaded Threaded
5 messages Options
sun
Reply | Threaded
Open this post in threaded view
|

怎么不使用checkpoint

sun
我们公司因为业务的问题,我们不需要生成checkpoint文件。有办法生成checkpoint文件吗,不需要这个恢复机制
Reply | Threaded
Open this post in threaded view
|

Re: 怎么不使用checkpoint

sysuke lee
你好,不设置checkpoint的情况下是不开启这个机制的

sun <[hidden email]> 于2020年1月17日周五 上午10:42写道:

> 我们公司因为业务的问题,我们不需要生成checkpoint文件。有办法生成checkpoint文件吗,不需要这个恢复机制
sun
Reply | Threaded
Open this post in threaded view
|

回复: 怎么不使用checkpoint

sun
是不是不要以下几行代码就是不开启这个机制的
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文件吗,不需要这个恢复机制
Reply | Threaded
Open this post in threaded view
|

Re: 回复: 怎么不使用checkpoint

Yun Tang
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文件吗,不需要这个恢复机制
sun
Reply | Threaded
Open this post in threaded view
|

回复: 回复: 怎么不使用checkpoint

sun
谢谢


------------------&nbsp;原始邮件&nbsp;------------------
发件人:&nbsp;"Yun Tang"<[hidden email]&gt;;
发送时间:&nbsp;2020年1月17日(星期五) 下午2:32
收件人:&nbsp;"[hidden email]"<[hidden email]&gt;;

主题:&nbsp;Re: 回复: 怎么不使用checkpoint



Hi

默认情况下,不调用env.enableCheckpoint,也就是不会启用checkpoint的。默认情况下的restart strategy就是NoRestart,也就是不会自动failover的。

祝好
唐云

获取 Outlook for Android<https://aka.ms/ghei36&gt;

________________________________
From: sun <[hidden email]&gt;
Sent: Friday, January 17, 2020 1:43:53 PM
To: user-zh <[hidden email]&gt;
Subject: 回复: 怎么不使用checkpoint

是不是不要以下几行代码就是不开启这个机制的
env.enableCheckpointing(CommonConstants.CHECK_POINTING);
env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime);
env.setParallelism(CommonConstants.PARALLELISM_NUMBER);
//作业失败后不重启
env.setRestartStrategy(RestartStrategies.noRestart());
//如果在此之前未完成,则中止正在执行的检查点的时间&nbsp; 默认 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);




------------------&amp;nbsp;原始邮件&amp;nbsp;------------------
发件人:&amp;nbsp;"sysuke Lee"<[hidden email]&amp;gt;;
发送时间:&amp;nbsp;2020年1月17日(星期五) 中午12:10
收件人:&amp;nbsp;"user-zh"<[hidden email]&amp;gt;;

主题:&amp;nbsp;Re: 怎么不使用checkpoint



你好,不设置checkpoint的情况下是不开启这个机制的

sun <[hidden email]&amp;gt; 于2020年1月17日周五 上午10:42写道:

&amp;gt; 我们公司因为业务的问题,我们不需要生成checkpoint文件。有办法生成checkpoint文件吗,不需要这个恢复机制