Hi, It seems there is a bug in the internal Table API operators: they store the Logger that is available on the Client machine and deserialising that Logger fails on the cluster. I created a Jira issue for this: https://issues.apache.org/jira/browse/FLINK-7398 <https://issues.apache.org/jira/browse/FLINK-7398>
Best, Aljoscha > On 26. Jul 2017, at 15:54, Nuno Rafael Goncalves > <nuno.goncal...@wedotechnologies.com> wrote: > > Even though I have executed the same code with intelliJ and works fine? <> > The only difference is that intelliJ is using log4j and the other application > is using logback. > Moreover, the snippet is quite simple, it does not reference any user class > other than flink's > Does flink uses user loaded log implementation and tries to use it on server > side? Which in this case would justify the logback dependency. > > From: Stephan Ewen [mailto:se...@apache.org <mailto:se...@apache.org>] > Sent: 26 de julho de 2017 14:42 > To: Nuno Rafael Goncalves <nuno.goncal...@wedotechnologies.com > <mailto:nuno.goncal...@wedotechnologies.com>> > Subject: Re: Logback user class > > You seem to have a reference to the Logback Logger somewhere in your code. > > The class for that logger seems to be not in the user code jar file, or in > the flink lib directory. > Since Flink does not bundle logback by itself, you need to package this > dependency explicitly or add the logback jar to the lib folder. > > On Wed, Jul 26, 2017 at 3:01 PM, nragon <nuno.goncal...@wedotechnologies.com > <mailto:nuno.goncal...@wedotechnologies.com>> wrote: > I've changed that line and compiled it into lib/. Error remains. > I'm running a local custer with start-local.sh > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Logback-user-class-tp14464p14469.html > > <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Logback-user-class-tp14464p14469.html> > Sent from the Apache Flink User Mailing List archive. mailing list archive at > Nabble.com.
