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
