при использовании Apache Flink 1.8 и попытке запустить RichAsyncFunction
.
И я получаю No Suitable Driver Found
ошибку при инициализации пула Hikari внутри RichAsyncFunction open()
В IDE это работаетотлично, при отправке в кластер я получаю вышеуказанную ошибку.
Я решил это, поставив Class.forName("net.sourceforge.jtds.jdbc.Driver")
Я предполагаю, что это какая-то проблема загрузки классов с тем, как Apache Flinkзагружает классы и толстые банки?Как и в случае с «последними» пулами и драйверами, вам больше не нужно это делать.JTDS - это драйвер типа 3, и Хикари обычно обнаруживает это в обычных толстых банках, которые я обычно создаю.
Мои зависимости Gradle таковы:
compile "net.sourceforge.jtds:jtds:${jtdsVersion}"
flinkShadowJar "net.sourceforge.jtds:jtds:${jtdsVersion}"