• 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

  • 相关阅读:
    文件操作之文件下载(32)
    【视频学习笔记】(霹雳吧啦Wz)MobileNet 系列
    Spark SQL底层执行流程详解
    嵌入式FreeRTOS学习十一,深入理解任务调度机制
    javascript追加标签
    智能汽车进入HPC时代,这家本土芯片厂商如何领跑市场
    服务端渲染学习笔记
    一文教你Kali信息收集
    快速幂原理以及python内置pow函数
    每日一结(11.8)
  • 原文地址:https://blog.csdn.net/qq_42747210/article/details/132889359