Flink 调优：Checkpoint 配置_flink program arguments

扫码关注公众号免费阅读全文：冰山烈焰的黑板报

在Flink 原理与实现：Checkpoint 这篇文章中介绍了 Flink Checkpoint 的原理以及作用，Flink 原理与实现：Savepoint
这篇文章讲述了 Flink Checkpoint 和 Savepoint 的异同。有了这些基础，你就可以在流式计算中对 Flink Checkpoint 进行配置了，下文会详细介绍各种配置方式，以及配置原则。

1. Checkpoint 的配置

在 Flink 应用程序中配置 Checkpoint，首先需要开启 Checkpoint，同时指定 Checkpoint 的时间间隔。

val env = StreamExecutionEnvironment.getExecutionEnvironment

// enable Checkpoint and set 10sec Checkpoint Interval
env.enableCheckpointing(10 * 1000)
1
2
3
4

为了对 Checkpoint 进行更多的配置，你需要拿到 CheckpointConfig：

val chkpConf = env.getCheckpointConfig
1

Flink 默认提供 Extractly-Once 保证 State 的一致性。这可以通过 CheckpointConfig 进行设置，Flink 提供了 Extractly-Once，