| Hi All, I am trying to run a small test job using HAMA graph api on a cluster configured with 10 nodes. My job creates 9 vertices, but it seems that HAMA is loading all the vertices into a single physical machine instead of distributing them onto different machine. I have attached the program. I simply reads the vertices from the input file, in the format ( <ID> <value> <neighbor_id>), the values and neighbors have no significance in this test program. In the compute method, the vertex finds it's peer name using this.getPeer().getPeerName(); and sets it as the value of the vertex, which is then dumped into the output Please help. I would like to make it run, so that the load is taken up by multiple physical machines. |
GraphTester.java
Description: Binary data
A node7:50434 B node7:50434 C node7:50434 D node7:50434 E node7:50434 F node7:50434 G node7:50434 H node7:50434 I node7:50434
A 1 B C C 2 A B 3 A E 2 A B D 1 A B C F 1 A B G 1 A C H 1 A D I 2 A C
Thanks Anveshi |
