flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stephan Ewen <se...@apache.org>
Subject Re: k means - waiting for dataset
Date Thu, 21 May 2015 10:23:20 GMT
Hi!

This problem should not depend on any user code. There are no user-code
dependent actors in Flink.

Is there more stack trace that you can send us? It looks like it misses the
core exception that is causing the issue is not part of the stack trace.

Greetings,
Stephan



On Thu, May 21, 2015 at 11:11 AM, Pa Rö <paul.roewer1990@googlemail.com>
wrote:

> hi flink community,
>
> i have implement k-means for clustering temporal geo data. i use the
> following github project and my own data structure:
>
> https://github.com/apache/flink/blob/master/flink-examples/flink-java-examples/src/main/java/org/apache/flink/examples/java/clustering/KMeans.java
>
> not i have the problem, that flink read the centroids from file and work
> parallel futher. if i look at the results, i have the feeling, that the
> prgramm load only one centroid point.
>
> i work with flink 0.8.1, if i update to 0.9 milestone 1 i get the
> following exception:
> ERROR actor.OneForOneStrategy: exception during creation
> akka.actor.ActorInitializationException: exception during creation
>     at akka.actor.ActorInitializationException$.apply(Actor.scala:218)
>     at akka.actor.ActorCell.create(ActorCell.scala:578)
>     at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:425)
>     at akka.actor.ActorCell.systemInvoke(ActorCell.scala:447)
>     at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:262)
>     at akka.dispatch.Mailbox.run(Mailbox.scala:218)
>     at
> akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:386)
>     at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
>     at
> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
>     at
> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
>     at
> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
> Caused by: java.lang.reflect.InvocationTargetException
>     at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native
> Method)
>     at
> sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
>     at
> sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
>     at java.lang.reflect.Constructor.newInstance(Constructor.java:526)
>     at akka.util.Reflect$.instantiate(Reflect.scala:65)
>     at akka.actor.Props.newActor(Props.scala:337)
>     at akka.actor.ActorCell.newActor(ActorCell.scala:534)
>     at akka.actor.ActorCell.create(ActorCell.scala:560)
>     ... 9 more
>
> how can i say flink, that it should be wait for loading dataset, and what
> say this exception?
>
> best regards,
> paul
>

Mime
View raw message