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 >
