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

FlinkCDC去读取pgsql的备库,备库因为同步主库一直处于恢复状态,同步就会报错为啥?

FlinkCDC去读取pgsql的备库,备库因为同步主库一直处于恢复状态,FlinkCDC同步就会报错:logical decoding cannot be used while in recovery,这种是不是FlinkCDC就不能同步了啊?

展开
收起
小小鹿鹿鹿 2024-01-18 07:43:23 97 0
2 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    是的,如果备库一直处于恢复状态,Flink CDC将无法同步数据。这是因为在恢复状态下,备库不允许使用逻辑解码(logical decoding),而Flink CDC依赖于逻辑解码来读取数据。

    要解决这个问题,你可以尝试以下方法:

    1. 等待备库完成恢复过程,然后再启动Flink CDC进行数据同步。
    2. 如果备库的恢复过程需要很长时间,你可以考虑使用其他方式来同步数据,例如通过定期备份主库并手动将备份文件传输到备库。
    3. 如果可能的话,尝试使用Flink CDC的其他版本或不同的CDC工具,看是否有更好的兼容性和处理恢复状态的能力。
    2024-01-19 15:07:28
    赞同 展开评论 打赏
  • 一直是不支持读取备库的pg哈,主库切换了只能重启job;postgres16支持了,等我们后续适配。此回答来自钉群Flink CDC 社区。

    2024-01-18 10:56:15
    赞同 展开评论 打赏

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

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载