Hi Stephan, yes, now it is solved. I was running an older version of the client by mistake.
Thanks Juan On Thu, 2015-07-23 at 15:31 +0200, Stephan Ewen wrote: > Hi! > > > Seems that you have different versions of the code running locally and > on the cluster. Is it possible that you did a code update locally > (client), and forgot to update the cluster (or the other way around)? > > > Greetings, > Stephan > > > > On Thu, Jul 23, 2015 at 3:10 PM, Juan Fumero > <juan.jose.fumero.alfo...@oracle.com> wrote: > Hi, > When I execute from Java the app in a cluster, the user app > is blocked in this point: > > log4j:WARN No appenders could be found for logger > (org.apache.flink.api.java.ExecutionEnvironment). > log4j:WARN Please initialize the log4j system properly. > log4j:WARN See > http://logging.apache.org/log4j/1.2/faq.html#noconfig for more > info. > > > I get this message in the jobManager log: > > 15:03:53,226 WARN akka.remote.ReliableDeliverySupervisor > - Association with remote system > [akka.tcp://flink@127.0.0.1:60400] has failed, address is now > gated for [5000] ms. Reason is: [Disassociated]. > 15:03:55,368 WARN akka.remote.ReliableDeliverySupervisor > - Association with remote system > [akka.tcp://flink@127.0.0.1:53211] has failed, address is now > gated for [5000] ms. Reason is: > [org.apache.flink.api.common.ExecutionConfig > $GlobalJobParameters; local class incompatible: stream > classdesc serialVersionUID = 5926998565449078053, local class > serialVersionUID = 1]. > > The user function is just a class which implements > MapFunction, Any idea? > > Many thanks > Juan > >
