Glad to hear it! On Mon, Aug 3, 2020 at 11:59 AM Flavio Pompermaier <pomperma...@okkam.it> wrote:
> Yes Till, I was figuring out that I was using 2 different connectors and I > forgot the mysql jar..I was going to test and tell if the problem was > solved! > > On Mon, Aug 3, 2020 at 10:50 AM Till Rohrmann <trohrm...@apache.org> > wrote: > >> 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 >>> >>
