You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by sun <13...@qq.com> on 2020/01/17 02:41:47 UTC
怎么不使用checkpoint
我们公司因为业务的问题，我们不需要生成checkpoint文件。有办法生成checkpoint文件吗，不需要这个恢复机制
回复： 回复： 怎么不使用checkpoint
Posted by sun <13...@qq.com>.
谢谢
------------------ 原始邮件 ------------------
发件人: "Yun Tang"<myasuka@live.com>;
发送时间: 2020年1月17日(星期五) 下午2:32
收件人: "user-zh@flink.apache.org"<user-zh@flink.apache.org>;
主题: Re: 回复： 怎么不使用checkpoint
Hi
默认情况下，不调用env.enableCheckpoint，也就是不会启用checkpoint的。默认情况下的restart strategy就是NoRestart，也就是不会自动failover的。
祝好
唐云
获取 Outlook for Android<https://aka.ms/ghei36>
________________________________
From: sun <1392427699@qq.com>
Sent: Friday, January 17, 2020 1:43:53 PM
To: user-zh <user-zh@flink.apache.org>
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"<sysukelee@gmail.com&gt;;
发送时间:&nbsp;2020年1月17日(星期五) 中午12:10
收件人:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;
主题:&nbsp;Re: 怎么不使用checkpoint
你好，不设置checkpoint的情况下是不开启这个机制的
sun <1392427699@qq.com&gt; 于2020年1月17日周五 上午10:42写道：
&gt; 我们公司因为业务的问题，我们不需要生成checkpoint文件。有办法生成checkpoint文件吗，不需要这个恢复机制
Re: 回复： 怎么不使用checkpoint
Posted by Yun Tang <my...@live.com>.
Hi
默认情况下，不调用env.enableCheckpoint，也就是不会启用checkpoint的。默认情况下的restart strategy就是NoRestart，也就是不会自动failover的。
祝好
唐云
获取 Outlook for Android<https://aka.ms/ghei36>
________________________________
From: sun <13...@qq.com>
Sent: Friday, January 17, 2020 1:43:53 PM
To: user-zh <us...@flink.apache.org>
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"<sysukelee@gmail.com>;
发送时间: 2020年1月17日(星期五) 中午12:10
收件人: "user-zh"<user-zh@flink.apache.org>;
主题: Re: 怎么不使用checkpoint
你好，不设置checkpoint的情况下是不开启这个机制的
sun <1392427699@qq.com> 于2020年1月17日周五 上午10:42写道：
> 我们公司因为业务的问题，我们不需要生成checkpoint文件。有办法生成checkpoint文件吗，不需要这个恢复机制
回复： 怎么不使用checkpoint
Posted by sun <13...@qq.com>.
是不是不要以下几行代码就是不开启这个机制的
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"<sysukelee@gmail.com>;
发送时间: 2020年1月17日(星期五) 中午12:10
收件人: "user-zh"<user-zh@flink.apache.org>;
主题: Re: 怎么不使用checkpoint
你好，不设置checkpoint的情况下是不开启这个机制的
sun <1392427699@qq.com> 于2020年1月17日周五 上午10:42写道：
> 我们公司因为业务的问题，我们不需要生成checkpoint文件。有办法生成checkpoint文件吗，不需要这个恢复机制
Re: 怎么不使用checkpoint
Posted by sysuke Lee <sy...@gmail.com>.
你好，不设置checkpoint的情况下是不开启这个机制的
sun <13...@qq.com> 于2020年1月17日周五 上午10:42写道：
> 我们公司因为业务的问题，我们不需要生成checkpoint文件。有办法生成checkpoint文件吗，不需要这个恢复机制