Return-Path: X-Original-To: apmail-flink-user-archive@minotaur.apache.org Delivered-To: apmail-flink-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id B2F501870D for ; Thu, 23 Jul 2015 13:11:37 +0000 (UTC) Received: (qmail 50648 invoked by uid 500); 23 Jul 2015 13:11:34 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 50577 invoked by uid 500); 23 Jul 2015 13:11:34 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 50566 invoked by uid 99); 23 Jul 2015 13:11:34 -0000 Received: from Unknown (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 23 Jul 2015 13:11:34 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id 065751A76DA for ; Thu, 23 Jul 2015 13:11:34 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.989 X-Spam-Level: ** X-Spam-Status: No, score=2.989 tagged_above=-999 required=6.31 tests=[HTML_MESSAGE=3, SPF_PASS=-0.001, T_RP_MATCHES_RCVD=-0.01] autolearn=disabled Received: from mx1-us-east.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id bUDc03MdqBLq for ; Thu, 23 Jul 2015 13:11:23 +0000 (UTC) Received: from aserp1040.oracle.com (aserp1040.oracle.com [141.146.126.69]) by mx1-us-east.apache.org (ASF Mail Server at mx1-us-east.apache.org) with ESMTPS id 846F443DCD for ; Thu, 23 Jul 2015 13:11:23 +0000 (UTC) Received: from aserv0022.oracle.com (aserv0022.oracle.com [141.146.126.234]) by aserp1040.oracle.com (Sentrion-MTA-4.3.2/Sentrion-MTA-4.3.2) with ESMTP id t6NDAM8o026108 (version=TLSv1 cipher=DHE-RSA-AES256-SHA bits=256 verify=OK) for ; Thu, 23 Jul 2015 13:10:22 GMT Received: from aserv0121.oracle.com (aserv0121.oracle.com [141.146.126.235]) by aserv0022.oracle.com (8.13.8/8.13.8) with ESMTP id t6NDAMX4005522 (version=TLSv1/SSLv3 cipher=DHE-RSA-AES256-SHA bits=256 verify=FAIL) for ; Thu, 23 Jul 2015 13:10:22 GMT Received: from abhmp0014.oracle.com (abhmp0014.oracle.com [141.146.116.20]) by aserv0121.oracle.com (8.13.8/8.13.8) with ESMTP id t6NDAMec027589 for ; Thu, 23 Jul 2015 13:10:22 GMT Received: from [140.78.145.159] (/140.78.145.159) by default (Oracle Beehive Gateway v4.0) with ESMTP ; Thu, 23 Jul 2015 06:10:21 -0700 Message-ID: <1437657022.16660.20.camel@laguna> Subject: Cluster Execution - log From: Juan Fumero To: user@flink.apache.org Date: Thu, 23 Jul 2015 15:10:22 +0200 Organization: Oracle Content-Type: multipart/alternative; boundary="=-Fx4GPQFP+mSjCABPWpRU" X-Mailer: Evolution 3.10.4-0ubuntu2 Mime-Version: 1.0 X-Source-IP: aserv0022.oracle.com [141.146.126.234] --=-Fx4GPQFP+mSjCABPWpRU Content-Type: text/plain; charset="UTF-8" Content-Transfer-Encoding: 7bit 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 --=-Fx4GPQFP+mSjCABPWpRU Content-Type: text/html; charset="utf-8" Content-Transfer-Encoding: 7bit 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 --=-Fx4GPQFP+mSjCABPWpRU--