flink checkpoint 重启_Flink Sql on Zeppelin之Checkpoint应用

1 概述

我们都知道，使用Scala或者Java写代码的时候可以配置Flink Checkpoint:

val env = StreamExecutionEnvironment.getExecutionEnvironment  .enableCheckpointing(5 * 60 * 1000)val checkpointConfig = env.getCheckpointConfigcheckpointConfig.setMinPauseBetweenCheckpoints(2 * 60 * 1000)checkpointConfig.setCheckpointTimeout(3 * 60 * 1000)checkpointConfig.enableExternalizedCheckpoints(ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION)

但这对于其他并不善于写代码的同事来说是很麻烦的事情，难以维护。我们使用Flink Sql + Zeppelin不就是想尽可能地干掉代码，使用纯SQL+配置吗？

好在Flink已经支持了Checkpoint相关配置，接下来开始介绍。

# Zeppelin配置Flink Checkpoint

%flink.conf# 开启Checkpoint，指定两次checkpoint开始调度之间的间隔，单位毫秒# 当然，还会受到checkpoint并发数和min-pause影响execution.checkpointing.interval