Nebula Exchange 导入MySQL数据 报错以及解决方案

Nebula Exchange2.0.0 导入MySQL8 一直报错 经过一天左右时间解决了报错问题

第一 我再启动参数里 加上了 --jars mysql-connector-java-8.0.22.jar
第二 Nebula Exchange 我加上了 driver 参数
第三 由于mysql8安全认证问题 需要 url 拼接 useSSL=false
编译打包运行就不再报错了

相关报错截图:

相关修改 代码如下:

  override def read(): DataFrame = {
val url =
  s"jdbc:mysql://${mysqlConfig.host}:${mysqlConfig.port}/${mysqlConfig.database}?useSSL=false&useUnicode=true&characterEncoding=utf-8"
session.read
  .format("jdbc")
  .option("url", url)
  .option("dbtable", mysqlConfig.table)
  .option("user", mysqlConfig.user)
  .option("password", mysqlConfig.password)
  .option("driver","com.mysql.jdbc.Driver")
  .load()

}

3 个赞

感谢 Dinwh 贡献了一个 Exchange 的小 Tips :star_struck:

1 个赞