Re: java.net.ConnectException: Connection refused

2014-11-08 Thread Puneet Agarwal
Thanks Xenia.I also managed to solve the issue. Following is how I solved it. I ran netstat on all the computers of my cluster, and I ran the gripah job in parallel.I then learnt that this process runs on 127.0.0.1 while other machine tries to connect on 172.21.xx.xxx. That's why It gives the

Issue in Aggregator

2014-11-08 Thread Puneet Agarwal
Hi All,In my algo, I use an Aggregator which takes a Text value. I have written my custom aggregator class for this, as given below. public class MyAgg extends BasicAggregatorText {...} This works fine when running on my laptop with one worker.However, when running it on the cluster, sometimes

Re: Help with Giraph on Yarn

2014-11-08 Thread Alessandro Negro
Hi Tripti, finally I was able to run the test with success. It was an issue of permission since I was running as ale not as yarn. Let me say that now I’m able to run graph examples on Yarn 2.5.1. This is the final result: 14/11/08 16:24:00 INFO yarn.GiraphYarnClient: Completed Giraph:

storeCheckpoint() in worker can be slow when a slow worker is presence

2014-11-08 Thread Vincentius Martin
Hi all, I have a question related to my last experience using Giraph. In Giraph worker's code, I see a line like this: *getServerData().getCurrentMessageStore().writePartition(verticesOutputStream, partition.getId());* To the best of my knowledge, while executing this line, a worker writes