You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@spark.apache.org by 杨强 <ya...@ict.ac.cn> on 2014/01/09 10:45:31 UTC

Lost of vertex when running a Bagel based program in non-local mode

Hi.

I wrote a program to implement KMeans algorithm with Bagel.
The program runs OK in local mode.
While when I try to run it in the cluster, it seems that the Bagel.run method
returns only part of vertices. That is, I used test data with 12 nodes to run the 
program and only 6 nodes was returned.

I'm using spark-0.8.0. The source file in attached.  Hope you can give me some advice.

Thanks,
Qiang Yang