flink配置checkpoint

在Flink中配置Checkpoint可以通过以下方式进行设置：

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
// 每间隔2000ms进行CheckPoint
env.enableCheckpointing(2000);
// 设置CheckPoint模式为EXACTLY_ONCE
env.getCheckpointConfig().setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE);
// 设置CheckPoint超时时间为50000ms
env.getCheckpointConfig().setCheckpointTimeout(50000);
// 设置最大并发的CheckPoint数量为1
env.getCheckpointConfig().setMaxConcurrentCheckpoints(1);
// 开启非对齐的CheckPoint
env.getCheckpointConfig().enableUnalignedCheckpoints();

其中，`enableCheckpointing(n)`方法用于开启Checkpoint，参数`n`表示以毫秒为单位的checkpoint间隔。`setCheckpointingMode()`方法用于设置Checkpoint模式，`setCheckpointTimeout()`方法用于设置Checkpoint超时时间，`setMaxConcurrentCheckpoints()`方法用于设置最大并发的Checkpoint数量，`enableUnalignedCheckpoints()`方法用于开启非对齐的Checkpoint。\[1\]

此外，在`flink-conf.yaml`配置文件中也可以进行Checkpoint的相关配置，主要包括state backend的配置，例如`state.backend.async`、`state.backend.incremental`、`state.checkpoints.dir`、`state.savepoints.dir`等。\[3\]
#### 引用[.reference_title]
- *1* *2* [flink的checkpoint配置](https://blog.csdn.net/weixin_43857576/article/details/122110132)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^control,239^v3^insert_chatgpt"}} ] [.reference_item]
- *3* [Flink的checkpoint配置详解](https://blog.csdn.net/worldchinalee/article/details/107716744)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^control,239^v3^insert_chatgpt"}} ] [.reference_item]
[ .reference_list ]