Re: Unaligned Checkpoint

2022-06-12 文章 Zhanghao Chen
你好, Unaligned checkpoint 是个底层特性,要使用的话只要设置 Flink 参数 execution.checkpointing.unaligned = true 就行,在 SQL client 中,可以使用 SET "key" = "value" 的语法设置 Flink 参数的值。 Unaligned checkpoint 较之 aligned checkpoint 主要的改变在于 * unaligned cp 在输入缓冲区收到第一个 cp barrier 的时候立即触发快照并直接输出至下游;代价是快照需要

Unaligned Checkpoint

2022-06-11 文章 小昌同学
大佬们可以说说Unaligned Checkpoint的实现吗 看了不少文档 没有太看懂 我如果想在sql里面实现 这个该怎么设置啊 请大佬们指教 | | 小昌同学 | | ccc0606fight...@163.com |