开发者社区> 问答> 正文

怎么不使用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);*来自志愿者整理的flink邮件归档

展开
收起
彗星halation 2021-12-02 17:54:06 715 0
1 条回答
写回答
取消 提交回答
  • 默认情况下,不调用env.enableCheckpoint,也就是不会启用checkpoint的。默认情况下的restart strategy就是NoRestart,也就是不会自动failover的。*来自志愿者整理的FLINK邮件归档

    2021-12-02 18:02:13
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

更多
俞航翔|基于Log的通用增量Checkpoint 立即下载
低代码开发师(初级)实战教程 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载