Mailing-List: contact dev-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@flink.apache.org
MIME-Version: 1.0
Sender: ewenstephan@gmail.com
In-Reply-To: <56FD3977.304@apache.org>
References: <56FD16FA.7000209@apache.org>
	<CAC27z=OaBxHz6mqPhhEFLgnn7akyg8N-jjSg+sNemZ-GKuryCQ@mail.gmail.com>
	<56FD3263.4040500@apache.org>
	<CAC27z=PrxN4pFc6_VzAtAWON5gasX5u97wJ2WUKBQ5wCHSWgPA@mail.gmail.com>
	<56FD3977.304@apache.org>
Date: Thu, 31 Mar 2016 17:05:37 +0200
Message-ID: 
 <CANC1h_uE03z7wJi6-LdA+W7Fc5sMhT7kT42-v3Cg5aiBAJfCfQ@mail.gmail.com>
Subject: Re: Submission Problem
From: Stephan Ewen <sewen@apache.org>
To: "dev@flink.apache.org" <dev@flink.apache.org>
Content-Type: multipart/alternative; boundary=94eb2c0810ac514bf6052f5998a5

--94eb2c0810ac514bf6052f5998a5
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

Hmm, it is wrong that the JobManager tries to load that class directly from
the actor message.
All user code should be deserialized lazily.

How is that class passed? Implicitly through some config?

On Thu, Mar 31, 2016 at 4:51 PM, Matthias J. Sax <mjsax@apache.org> wrote:

> Here we go...
>
> StormConfig.class is contained in the user jar file. I guess I need to
> "register" it somehow? Or is it a class loading issue?
>
>
> > 2016-03-31 16:47:33,095 ERROR akka.remote.EndpointWriter
>                     - AssociationError [akka.tcp://flink@127.0.0.1:6123]
> <- [akka.tcp://flink@127.0.0.1:32775]: Error
> [org.apache.flink.storm.util.StormConfig] [
> > java.lang.ClassNotFoundException: org.apache.flink.storm.util.StormConf=
ig
> >       at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
> >       at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
> >       at java.security.AccessController.doPrivileged(Native Method)
> >       at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
> >       at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
> >       at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
> >       at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
> >       at java.lang.Class.forName0(Native Method)
> >       at java.lang.Class.forName(Class.java:278)
> >       at
> java.io.ObjectInputStream.resolveClass(ObjectInputStream.java:625)
> >       at
> akka.util.ClassLoaderObjectInputStream.resolveClass(ClassLoaderObjectInpu=
tStream.scala:19)
> >       at
> java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1612)
> >       at
> java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1517)
> >       at
> java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1771)
> >       at
> java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1350)
> >       at
> java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1997)
> >       at
> java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1921)
> >       at
> java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1798)
> >       at
> java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1350)
> >       at
> java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1997)
> >       at
> java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1921)
> >       at
> java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1798)
> >       at
> java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1350)
> >       at
> java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1997)
> >       at
> java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1921)
> >       at
> java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1798)
> >       at
> java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1350)
> >       at
> java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1997)
> >       at
> java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1921)
> >       at
> java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1798)
> >       at
> java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1350)
> >       at java.io.ObjectInputStream.readObject(ObjectInputStream.java:37=
0)
> >       at
> akka.serialization.JavaSerializer$$anonfun$1.apply(Serializer.scala:136)
> >       at scala.util.DynamicVariable.withValue(DynamicVariable.scala:57)
> >       at
> akka.serialization.JavaSerializer.fromBinary(Serializer.scala:136)
> >       at
> akka.serialization.Serialization$$anonfun$deserialize$1.apply(Serializati=
on.scala:104)
> >       at scala.util.Try$.apply(Try.scala:161)
> >       at
> akka.serialization.Serialization.deserialize(Serialization.scala:98)
> >       at
> akka.remote.MessageSerializer$.deserialize(MessageSerializer.scala:23)
> >       at
> akka.remote.DefaultMessageDispatcher.payload$lzycompute$1(Endpoint.scala:=
58)
> >       at
> akka.remote.DefaultMessageDispatcher.payload$1(Endpoint.scala:58)
> >       at akka.remote.DefaultMessageDispatcher.dispatch(Endpoint.scala:7=
6)
> >       at
> akka.remote.EndpointReader$$anonfun$receive$2.applyOrElse(Endpoint.scala:=
937)
> >       at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
> >       at akka.remote.EndpointActor.aroundReceive(Endpoint.scala:415)
> >       at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
> >       at akka.actor.ActorCell.invoke(ActorCell.scala:487)
> >       at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
> >       at akka.dispatch.Mailbox.run(Mailbox.scala:221)
> >       at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
> >       at
> scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
> >       at
> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.jav=
a:1339)
> >       at
> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
> >       at
> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.j=
ava:107)
> > ]
>
>
>
> On 03/31/2016 04:31 PM, Till Rohrmann wrote:
> > Could you please rerun the whole job with debug log level and logging o=
f
> > Akka's lifecycle events turned on?
> >
> > Cheers,
> > Till
> >
> > On Thu, Mar 31, 2016 at 4:21 PM, Matthias J. Sax <mjsax@apache.org>
> wrote:
> >
> >> enclosed the logs.. maybe you can make some sense out if them.
> >>
> >> On 03/31/2016 02:52 PM, Till Rohrmann wrote:
> >>> I would assume that something went wrong on the JobManager side. Coul=
d
> >> you
> >>> check the logs if they contain something suspicious? Additionally you
> >> could
> >>> turn on lifecycle event logging=E2=80=8B for Akka.
> >>>
> >>> Cheers,
> >>> Till
> >>> =E2=80=8B
> >>>
> >>
> >
>
>

--94eb2c0810ac514bf6052f5998a5--