java Apache Flink、JDBC和fat JAR是否存在类加载问题?
使用ApacheFlink1.8并尝试运行RichAsyncFunction
在初始化RichAsyncFunction open()
内的Hikari池时,我得到了No Suitable Driver Found
错误
在IDE中,它工作得很好,当提交到集群时,我得到了上面的错误
我通过放置Class.forName("net.sourceforge.jtds.jdbc.Driver")
解决了这个问题
我猜这是ApacheFlink如何加载类和胖jar的类加载问题?与“最新”的池和驱动程序一样,您真的不必再这样做了。JTDS是一个3型驱动程序,Hikari似乎通常在我通常创建的普通胖罐子中检测到这一点
我的Gradle依赖项如下所示:
compile "net.sourceforge.jtds:jtds:${jtdsVersion}"
flinkShadowJar "net.sourceforge.jtds:jtds:${jtdsVersion}"
共 (0) 个答案