Cluster Execution - log

[Juan Fumero]

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://[hidden email]: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://[hidden email]: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

[Stephan Ewen]

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 <[hidden email]> 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://[hidden email]: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://[hidden email]: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

[Juan Fumero]

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
> <[hidden email]> 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
>
>