Concerning your first problem that you only see one resulting centroid, your code looks good modulo the parts you haven't posted.
However, your problem could simply be caused by a bad selection of initial centroids. If, for example, all centroids except for one don't get any points assigned, then only one centroid will survive the iteration step. How do you do it? To check that all centroids are read you can print the contents of the centroids DataSet. Furthermore, you can simply println the new centroids after each iteration step. In local mode you can then observe the computation. Cheers, Till On Thu, May 21, 2015 at 12:23 PM, Stephan Ewen <se...@apache.org> wrote: > 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 >> > >
