你好，
Unaligned checkpoint 是个底层特性，要使用的话只要设置 Flink 参数
execution.checkpointing.unaligned = true 就行，在 SQL client 中，可以使用 SET "key" =
"value" 的语法设置 Flink 参数的值。
Unaligned checkpoint 较之 aligned checkpoint 主要的改变在于
* unaligned cp 在输入缓冲区收到第一个 cp barrier
的时候立即触发快照并直接输出至下游；代价是快照需要记录缓冲区中的数据来保证一致性，产生更多 io 并增大 cp 大小。
* aligned cp 在算子收到最后一个 cp barrier 完成 barrier 对齐后才触发快照，barrier 对齐期间较早收到
barrier 的 input channel 会被阻塞，在反压时阻塞时间会显著增加，导致 cp 速度变慢；好处是 barrier
对齐的过程使得快照不需要记录缓冲等待队列中的数据就可以保证一致性。
Best,
Zhanghao Chen
From: 小昌同学
Sent: Saturday, June 11, 2022 17:18
To: user-zh@flink.apache.org
Subject: Unaligned Checkpoint
大佬们可以说说Unaligned Checkpoint的实现吗 看了不少文档 没有太看懂 我如果想在sql里面实现 这个该怎么设置啊 请大佬们指教
| |
小昌同学
|
|
ccc0606fight...@163.com
|
