flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Juan Fumero <juan.jose.fumero.alfo...@oracle.com>
Subject Cluster Execution - log
Date Thu, 23 Jul 2015 13:10:22 GMT
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

Mime
View raw message