我这边解决了,Committer 提交数据是依赖 Checkpoint 完成的,过程:尝试了很多参数去配置 Checkpoint 的 Interval,最后是 conf/config.yaml 下的 execution.checkpointing.interval 生效了,能产生 Checkpoint,数据成功写到 Paimon。
在 2025-02-20 18:02:50,"AaronFae" <aaron...@163.com> 写道: > > > >我是数据能到Sink Writer阶段,到不了Sink Committer,没有产生Checkpoint,目前还在排查。 > > > > > > > > > > > > > >在 2025-02-08 17:41:30,"Mobile" <gongzexin997874...@qq.com.INVALID> 写道: > >各位开发者,你们好! > > > 我在使用flink-cdc > 3.3.0,想要将mysql数据整库同步至paimon中。flink-cdc任务提交正常,flink集群也正常,但是观察到source的Records > Sent指标长时间未发生变化,而后排查到sink算子有接收到数据但未正常写入paimon(详见附件)。请问我该如何排查并解决这一问题呢? > > >祝好!