问答 2024-08-12 来自:开发者社区

在Flink CDC中,mysql修改为+8后,重启了cdc服务,请问应该从哪里进行排查?

在Flink CDC中,mysql修改为+8后,重启了cdc服务,读取的时间还是多了8小时,请问应该从哪里进行排查?

问答 2024-08-02 来自:开发者社区

flink 累计重启如何排查问题?

flink 累计重启如何排查问题?

问答 2023-01-15 来自:开发者社区

对于Flink CDC,从丢失时刻的checkpoint重启任务,丢失的数据又获取到了。有排查方向吗

目前生产flink14+cdc2.3+mongo4,使用datastream api的方式进行整库订阅,出现数据丢失的情况。在日志中没有任何报错异常。但是我发现数据丢失后,从丢失时刻的checkpoint重启任务,丢失的数据又获取到了。也尝试调了poll.await.time.ms、heartbeat.interval.ms等参数,没有效果。请问有什么排查方向吗?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注