flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "sun" <1392427...@qq.com>
Subject 回复: 回复: 怎么不使用checkpoint
Date Fri, 17 Jan 2020 08:03:49 GMT
谢谢


------------------&nbsp;原始邮件&nbsp;------------------
发件人:&nbsp;"Yun Tang"<myasuka@live.com&gt;;
发送时间:&nbsp;2020年1月17日(星期五) 下午2:32
收件人:&nbsp;"user-zh@flink.apache.org"<user-zh@flink.apache.org&gt;;

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



Hi

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

祝好
唐云

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

________________________________
From: sun <1392427699@qq.com&gt;
Sent: Friday, January 17, 2020 1:43:53 PM
To: user-zh <user-zh@flink.apache.org&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"<sysukelee@gmail.com&amp;gt;;
发送时间:&amp;nbsp;2020年1月17日(星期五) 中午12:10
收件人:&amp;nbsp;"user-zh"<user-zh@flink.apache.org&amp;gt;;

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



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

sun <1392427699@qq.com&amp;gt; 于2020年1月17日周五 上午10:42写道:

&amp;gt; 我们公司因为业务的问题,我们不需要生成checkpoint文件。有办法生成checkpoint文件吗,不需要这个恢复机制
Mime
  • Unnamed multipart/alternative (inline, 8-Bit, 0 bytes)
View raw message