开发者社区 问答 正文

怎么不使用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 760 分享 版权
1 条回答
写回答
取消 提交回答
  • 默认情况下,不调用env.enableCheckpoint,也就是不会启用checkpoint的。默认情况下的restart strategy就是NoRestart,也就是不会自动failover的。*来自志愿者整理的FLINK邮件归档

    2021-12-02 18:02:13
    赞同 展开评论
问答地址: