开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

请问我同步postgre的表,分区表数据同步不了,非分区表可以,有朋友遇到类似的问题么 2023-0

请问我同步postgre的表,分区表数据同步不了,非分区表可以,有朋友遇到类似的问题么 2023-03-27 17:51:42,827 WARN io.debezium.relational.RelationalDatabaseSchema [] - After applying the include/exclude list filters, no changes will be captured. Please check your configuration!

展开
收起
十一0204 2023-04-05 09:05:26 227 0
1 条回答
写回答
取消 提交回答
  • 意中人就是我呀!

    "flinkcdc报错 WARN io.debezium.relational.RelationalDatabaseSchema 1 - Afterapplying the include/exclude list filters, no changes will be captured. Pleasecheck your configuration! 这个错误通常是由于flinkcdc的配置文件中的include/exclude过滤条件设置不正确导致的。在flinkcdc的配置文件中,可以通过设置include/exclude过滤条件来过滤要捕获的数据变化。如果设置不正确,可能会导致无法捕获任何数据变化,从而出现上述的警告信息。 解决这个问题的方法是: 检查flinkcdc的配置文件中的include/exclude过滤条件是否正确。确保过滤条件能够正确地匹配到要捕获的数据变化 2.如果include/exclude过滤条件设置正确,但仍然出现上述警告信息,可以尝试重新启动flinkcdc,并观察是否能够正常捕获数据变化。 3.如果以上方法都无法解决问题,可以尝试检查数据库中的数据是否存在异常,例如重复数据等。如果存在异常,需要先修复数据,然后重新启动flinkcdc. 总之,需要仔细检查flinkcdc的配置文件中的include/exclude过滤条件,并确保数据变化能够正确地被捕获。如果无法解决问题,可以尝试重新启动flinkcdc或者联系flinkcdc官方技术支持。此回答整理自钉群“Flink CDC 社区”"

    2023-04-05 10:29:08
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关电子书

更多
MaxCompute技术公开课第四季 之 如何将Kafka数据同步至MaxCompute 立即下载
低代码开发师(初级)实战教程 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载