问答 2023-12-05 来自:开发者社区

Flink CDC 无法从检查点处恢复pg同步任务,而是从头对pg数据库又消费了一遍?

Flink CDC 1.13.2、flinkcdc 2.2.1、postgresql 13.82.问题:使用cdc对pg做数据同步时checkpoint可以正常触发保存到hdfs,当任务取消后再从checkpoint进行任务恢复时,无法从检查点处恢复pg同步任务,而是从头对pg数据库又消费了一遍?

问答 2023-12-04 来自:开发者社区

Flink CDC任务总是报错这个怎么解决哇?

Flink CDC任务总是报错这个怎么解决哇?org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. at io.debezium.pipeline.ErrorHandler.se...

问答 2023-12-04 来自:开发者社区

Flink CDC有没有遇到归档日志定时清理导致任务失败的场景哇?

Flink CDC有没有遇到归档日志定时清理导致任务失败的场景哇?

问答 2023-12-04 来自:开发者社区

Flink CDC这是什么问题?今天所有任务都停失败了 ?

Flink CDC这是什么问题?今天所有任务都停失败了 ?2023-11-28 13:49:59java.io.IOException: Failed to fetch BLOB d14e8c48ad24201e9d7cbe8bd3e7e89f/p-a7e583f106f46d88b8ae9170727681965bda51d4-275a43c1606a617665ee9351bfbdb899 ....

问答 2023-12-04 来自:开发者社区

Flink CDC 2.3.0? update_time = 昨天时间,这个任务资源是一直暂用的吗?

Flink CDC 2.3.0?update_time = 昨天时间,这个任务资源是一直暂用的吗?还是需要通过调度启动?

问答 2023-12-04 来自:开发者社区

Flink CDC任务里有三个 全量+增量 的数据同步。并没有下降(如下图红框),这是为什么呀?

Flink CDC任务里有三个 全量+增量 的数据同步。现在有两个已经完成了全量同步(如上图蓝框),但是我查看任务所占的内存,并没有下降(如下图红框),这是为什么呀?是否正常,可否优化?

问答 2023-12-04 来自:开发者社区

Flink CDC同样的任务 测试环境和生产都是读同一份binlog日志,生产的出错了缺数据了?

Flink CDC同样的任务 测试环境和生产都是读同一份binlog日志,生产的出错了缺数据了,测试环境的还正常读到数据?

问答 2023-12-04 来自:开发者社区

Flink CDC最近的任务经常出现这个错误 导致cdc同步失败,有啥措施能减少这个情况的发生么?

Flink CDC最近的任务经常出现这个错误 导致cdc同步失败,多次重启也不行,只能重新启动任务从最新的消费,缺的数据需要手动补,有人也有遇到这个情况,有啥措施能减少这个情况的发生么?Caused by: com.github.shyiko.mysql.binlog.event.deserialization.MissingTableMapEventException: No TableMap....

问答 2023-12-04 来自:开发者社区

Flink CDC如何评估运行任务与资源需求的关系呀?

Flink CDC如何评估运行任务与资源需求的关系呀?

问答 2023-12-04 来自:开发者社区

Flink CDC这种是跑完了自动结束任务吗,每天去提交一个任务?

Flink CDC这种是跑完了自动结束任务吗,每天去提交一个任务?

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

产品推荐

阿里云实时计算Flink

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

+关注