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()
}
