- `execution.checkpointing.interval`: 檢查點之間的時間間隔（以毫秒為單位）。在此間隔內，系統(tǒng)將生成新的檢查點
SET?execution.checkpointing.interval?=?6000;
- `execution.checkpointing.tolerable-failed-checkpoints`: 允許的連續(xù)失敗檢查點的最大數量。如果連續(xù)失敗的檢查點數量超過此值，作業(yè)將失敗。
SET?execution.checkpointing.tolerable-failed-checkpoints?=?10;
- `execution.checkpointing.timeout`: 檢查點的超時時間（以毫秒為單位）。如果在此時間內未完成檢查點操作，作業(yè)將失敗。
SET?execution.checkpointing.timeout?=600000;文章來源：http://www.zghlxwxcb.cn/news/detail-664220.html
- `execution.checkpointing.externalized-checkpoint-retention`: 外部化檢查點的保留策略。`RETAIN_ON_CANCELLATION`表示在作業(yè)取消時保留外部化檢查點。
SET?execution.checkpointing.externalized-checkpoint-retention?=?RETAIN_ON_CANCELLATION;
- `execution.checkpointing.mode`: 檢查點模式。`EXACTLY_ONCE`表示每個檢查點只會在作業(yè)處理完全一次時生成。
SET?execution.checkpointing.mode?=?EXACTLY_ONCE;
- `execution.checkpointing.unaligned`: 檢查點是否對齊。如果設置為`true`，則檢查點將在作業(yè)的所有任務完成之前生成。
SET?execution.checkpointing.unaligned?=?true;
- `execution.checkpointing.max-concurrent-checkpoints`: 并發(fā)生成檢查點的最大數量。在此數量的檢查點生成之前，不會生成新的檢查點。
SET?execution.checkpointing.max-concurrent-checkpoints?=?1;
- `state.checkpoints.num-retained`: 保留的檢查點數量。超過此數量的檢查點將被刪除
SET?state.checkpoints.num-retained?=?3;
暫未使用
SET?execution.checkpointing.interval?=?6000;
SET?execution.checkpointing.tolerable-failed-checkpoints?=?10;
SET?execution.checkpointing.timeout?=600000;
SET?execution.checkpointing.externalized-checkpoint-retention?文章來源地址http://www.zghlxwxcb.cn/news/detail-664220.html
到了這里，關于flink sql checkpoint 調優(yōu)配置的文章就介紹完了。如果您還想了解更多內容，請在右上角搜索TOY模板網以前的文章或繼續(xù)瀏覽下面的相關文章，希望大家以后多多支持TOY模板網！
