Re: flink两阶段提交

[Feng Jin]

hi,

可以参考这篇博客，描述的非常清晰：
https://flink.apache.org/2018/02/28/an-overview-of-end-to-end-exactly-once-processing-in-apache-flink-with-apache-kafka-too/


Best,
Feng

On Sun, Sep 24, 2023 at 9:54 PM 海风 <18751805...@163.com> wrote:

> 请教一下，flink的两阶段提交对于sink算子，预提交是在做检查点的哪个阶段触发的？预提交时具体是做了什么工作？
>
>
>

Re: Flink CDC消费Apache Paimon表

[Feng Jin]

hi casel

Flink 实时消费 paimon，默认情况就是全量 + 增量的方式。

具体可以参考：  https://paimon.apache.org/docs/master/maintenance/configurations/
中的 scan.mode 参数


best,
Feng

On Fri, Sep 29, 2023 at 5:50 PM casel.chen  wrote:

> 目前想要通过Flink全量+增量消费Apache Paimon表需要分别起离线和增量消费两个作业，比较麻烦，而且无法无缝衔接，能否通过类似Flink
> CDC消费mysql表的方式消费Apache Paimon表？