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

大佬们知道这个报错 如何解决吗?测试 我只是用IDEA把Flink cdc作为一个监听binlog的

问题1:大佬们知道这个报错 如何解决吗?com.ververica.cdc.connectors.mysql.debezium.task.context.exception.schemaoutofsyncexception: Internal schema representation is probably out of sync with real database schema. The reason could be that the table schema was changed after the starting binlog offset, which is not supported when startup mode is set to SPECIFIC_OFFSETS测试 我只是用IDEA把Flink cdc作为一个监听binlog的组件,我也不知道是新任务还是旧任务,以前跑还是没问题的 突然就报这个错了 我重新设置启动的offset为0也没用,mysql 5.7 flink2.3。是的 监听的库 有过字段改动 问题2:把binlog文件清了吗?那以后 修改mysql字段 都需要清空binlog文件嘛?只要不删字段 就不会报这错是嘛?

展开
收起
真的很搞笑 2023-06-18 14:05:08 134 0
1 条回答
写回答
取消 提交回答
  • 回答1:你是新任务还是旧任务,生产还是测试。mysql版本,cdc版本,中间mysql是都有删字段?增加字段,修改字段?是的,那就把binlog给清了就行,清空binlog 回答2:以后修改mysql字段不可以删字段,or给字段改名,你应该新增一个字段,这是在开发中不被允许的,除非你把ddl语句也适配加上,自己改很难得,你去搞个ctas语法就行,或者你自己适配ddl语句变更https://help.aliyun.com/document_detail/374303.html?spm=a2c4g.386381.0.i10,此回答整理自钉群“Flink CDC 社区”

    2023-06-18 15:33:30
    赞同 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 热门讨论

    热门文章

    相关电子书

    更多
    Flink峰会 - 陈政羽 立即下载
    Flink峰会 - 李佳林 立即下载
    蚂蚁金服高级开发工程师萧恺:IDEA 插件开发入门教程 立即下载