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算子,预提交是在做检查点的哪个阶段触发的?预提交时具体是做了什么工作?
>
>
>
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表的方式消费