• Otter同步报错 Caused by: java.lang.NoSuchFieldError: MYSQL


    1. 报错日志

    pid:2 nid:1 exception:canal:canal4:com.alibaba.otter.canal.parse.exception.CanalParseException: java.lang.NoSuchFieldError: MYSQL
    Caused by: java.lang.NoSuchFieldError: MYSQL
    at com.alibaba.otter.canal.parse.inbound.mysql.ddl.DruidDdlParser.parse(DruidDdlParser.java:51)
    at com.alibaba.otter.canal.parse.inbound.mysql.dbsync.LogEventConvert.parseQueryEvent(LogEventConvert.java:258)
    at com.alibaba.otter.canal.parse.inbound.mysql.dbsync.LogEventConvert.parse(LogEventConvert.java:120)
    at com.alibaba.otter.canal.parse.inbound.mysql.dbsync.LogEventConvert.parse(LogEventConvert.java:71)
    at com.alibaba.otter.canal.parse.inbound.AbstractEventParser.parseAndProfilingIfNecessary(AbstractEventParser.java:414)
    at com.alibaba.otter.canal.parse.inbound.AbstractEventParser$1$1.sink(AbstractEventParser.java:214)
    at com.alibaba.otter.canal.parse.inbound.mysql.MysqlConnection.dump(MysqlConnection.java:185)
    at com.alibaba.otter.canal.parse.inbound.AbstractEventParser$1.run(AbstractEventParser.java:276)
    at java.lang.Thread.run(Thread.java:748)
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11

    2. 原因分析

    java.lang.NoSuchFieldError 通常是访问了某个类不存在的成员变量,可能是代码没编译更新,或者使用了不同版本的依赖。

    在Otter这里是使用了不同的 Druid 版本。

    Canal 1.1.5中 Druid版本为1.2.6,Otter中被改为了1.1.9。

    3. 解决办法

    有2个步骤,亲测有效:

    1 修改Druid版本

    otter项目最外层的pom文件194行
    1.1.9 改成 1.2.6

    2 更新代码

    // 130if (x.isIfNotExiists()) {
                print0(ucase ? "IF NOT EXISTS " : "if not exists ");
    }
    // 改成(拼写错误)
    if (x.isIfNotExists()) {
                print0(ucase ? "IF NOT EXISTS " : "if not exists ");
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    // 158239for (Map.Entry<String, SQLObject> option : x.getTableOptions().entrySet()) {
                    String key = option.getKey();
    ...
    // 改成(方法改变)
     for (SQLAssignItem option : x.getTableOptions()) {
                    String key = ((SQLIdentifierExpr) option.getTarget()).getName();
    ...
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8

    需要注意:
    1 文件位置: node/etl/src/main/java/com/alibaba/otter/node/etl/common/db/utils/DdlUtils.java
    2 需要 import com.alibaba.druid.sql.ast.statement.SQLAssignItem;

    可以参考 github issue
    https://github.com/alibaba/otter/issues/1068

  • 相关阅读:
    【linux驱动】简单字符设备驱动
    LeetCode(力扣)763. 划分字母区间Python
    使用`archinstall`安装`Arch Linux`
    416. 分割等和子集
    Kafka - 05 Kafka生产者| 消息发送方式 | 序列化器 | 分区器 | 拦截器 |生产者配置参数
    求两个单链表的第一个交点
    Java项目:JSP健身房管理系统
    Appium自动化测试基础 — ADB常用命令(三)
    小程序容器技术助力券商数字营销突围
    图像处理--形态学处理
  • 原文地址:https://blog.csdn.net/qq_42747210/article/details/132889359