Hi Flavio, I am not a JDBC expert but it looks as if you try to load com.mysql.cj.jdbc.Driver which is not contained in mariadb-java-client-2.6.0.jar. mariadb-java-client-2.6.0.jar only contains org/mariadb/jdbc/Driver.class. com.mysql.cj.jdbc.Driver can be found in mysql-connector-java.jar, though.
Hence I believe that you are missing some dependencies in your user jar to make your job run. Please check from where com.mysql.cj.jdbc.Driver is being loaded when running the job from the IDE. Cheers, Till On Fri, Jul 31, 2020 at 4:55 PM Flavio Pompermaier <pomperma...@okkam.it> wrote: > Hi to all, > I'm trying to run my DataSet job on Flink 1.11.0 and I'm connecting toward > Mariadb in my code. > I've put the mariadb-java-client-2.6.0.jar in the lib directory and in the > pom.xml I set that dependency as provided. The code runs successfully from > the Ide but when I try to run the code on the cluster I get the following > error: > > Caused by: java.lang.ClassNotFoundException: com.mysql.cj.jdbc.Driver > at java.net.URLClassLoader.findClass(URLClassLoader.java:471) ~[?:?] > at java.lang.ClassLoader.loadClass(ClassLoader.java:589) ~[?:?] > at > org.apache.flink.util.FlinkUserCodeClassLoader.loadClassWithoutExceptionHandling(FlinkUserCodeClassLoader.java:61) > ~[flink-dist_2.12-1.11.0.jar:1.11.0] > at > org.apache.flink.util.ChildFirstClassLoader.loadClassWithoutExceptionHandling(ChildFirstClassLoader.java:74) > ~[flink-dist_2.12-1.11.0.jar:1.11.0] > at > org.apache.flink.util.FlinkUserCodeClassLoader.loadClass(FlinkUserCodeClassLoader.java:48) > ~[flink-dist_2.12-1.11.0.jar:1.11.0] > at java.lang.ClassLoader.loadClass(ClassLoader.java:522) ~[?:?] > at java.lang.Class.forName0(Native Method) ~[?:?] > at java.lang.Class.forName(Class.java:315) ~[?:?] > at > org.apache.flink.connector.jdbc.internal.connection.SimpleJdbcConnectionProvider.getConnection(SimpleJdbcConnectionProvider.java:52) > ~myApp.jar:?] > at > org.apache.flink.connector.jdbc.internal.AbstractJdbcOutputFormat.establishConnection(AbstractJdbcOutputFormat.java:66) > ~myApp.jar:?] > at > org.apache.flink.connector.jdbc.internal.AbstractJdbcOutputFormat.open(AbstractJdbcOutputFormat.java:59) > ~myApp.jar:?] > at > org.apache.flink.api.java.io.jdbc.JDBCOutputFormat.open(JDBCOutputFormat.java:82) > ~myApp.jar:?] > at > org.apache.flink.runtime.operators.DataSinkTask.invoke(DataSinkTask.java:205) > ~[flink-dist_2.12-1.11.0.jar:1.11.0] > at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:721) > ~[flink-dist_2.12-1.11.0.jar:1.11.0] > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:546) > ~[flink-dist_2.12-1.11.0.jar:1.11.0] > at java.lang.Thread.run(Thread.java:834) ~[?:?] > > What should I do? > > Thanks in advance, > Flavio >
