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.roewer1...@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 >
