flink.checkpoint.maxcurrent=1
时间: 2024-04-14 10:32:09 浏览: 114
Flink Unaligned Checkpoint 在 Shopee 的优化和实践.pdf
`flink.checkpoint.maxcurrent=1` 是一个配置参数,用于设置 Apache Flink 应用程序的最大并行检查点数。
在 Apache Flink 中,检查点是为了实现容错性而创建的应用程序状态的一致性快照。检查点操作涉及将应用程序的状态写入持久化存储,以便在发生故障时进行恢复。
`flink.checkpoint.maxcurrent=1` 设置了最大并行检查点数为 1。这意味着在任何给定时间只能有一个检查点操作正在执行。
通过限制并行检查点数,可以控制资源的使用和负载。较小的并行检查点数可以减少资源竞争和冲突,但可能会增加故障恢复时间。较大的并行检查点数可以提高故障恢复速度,但可能会增加资源消耗。
需要根据应用程序的需求、系统资源和容错性要求进行权衡,选择适当的最大并行检查点数。
总结起来,`flink.checkpoint.maxcurrent=1` 是一个配置参数,用于设置 Apache Flink 应用程序的最大并行检查点数为 1,以控制资源使用和故障恢复速度。
阅读全文