master knowing about message traffic

2013-10-21 Thread Jyoti Yadav
Is there any way for the master to know about how much message traffic is there? In my algo, I have to implement something when there is no msg flowing. Any ideas are really appreciated.. Regards Jyoti

Re: master knowing about message traffic

2013-10-21 Thread Claudio Martella
The most simple solution is to use an aggregator. On Mon, Oct 21, 2013 at 3:48 PM, Jyoti Yadav rao.jyoti26ya...@gmail.comwrote: Is there any way for the master to know about how much message traffic is there? In my algo, I have to implement something when there is no msg flowing. Any ideas

Re: Problem running the PageRank example in a cluster

2013-10-21 Thread Simon McGloin
Hey Andro, I believe the reason you are seeing this error is due to ports being blocked by iptables. You need to have port 3 open for the master on all machines in your cluster. You also need to open ports 30001 up to the number of workers you will be running. So if you are running 10 workers

Re: Problem running the PageRank example in a cluster

2013-10-21 Thread Claudio Martella
Yes, that would be the reason. In addition to the ports for netty, you also need to accept connections to Zookeeper (e.g. 22181). On Mon, Oct 21, 2013 at 5:06 PM, Simon McGloin simonmcgl...@gmail.comwrote: Hey Andro, I believe the reason you are seeing this error is due to ports being

Where are the job configurations?

2013-10-21 Thread ikapoura
Hello there! today I came back from a long vacation from programming with giraph. I compiled the latest version and I am so lost with the changes! So, can anybody help me with the following questions? Q1: Where are all the job.set functions from GiraphJob? Like job.setVertexClass(),

java.lang.OutOfMemoryError: Java heap space

2013-10-21 Thread Puneet Jain
Hello: I have a graph of size 2B edges, 200M vertices. I am trying to compute pagerank of this graph. I have 10 node cluster, 8G memory. I am unable to run giraph job successfully. My question is more generic: 1. How should one choose right amount of heap space? .. is there a way of telling

Re: Problem running the PageRank example in a cluster

2013-10-21 Thread Simon McGloin
Are you sure the iptables rules were applied to all your servers? If you run the command sudo iptables -L does it show the ports as open? On Mon, Oct 21, 2013 at 8:16 PM, Andro Bermúdez Serrano andro.bermu...@gmail.com wrote: I added this two lines: iptables -A INPUT -p tcp -m state --state

Re: Problem running the PageRank example in a cluster

2013-10-21 Thread Andro Bermúdez Serrano
this is the output of the command in all servers: Chain INPUT (policy ACCEPT) target prot opt source destination ACCEPT tcp -- anywhere anywhere state NEW tcp dpts:3:30010 ACCEPT tcp -- anywhere anywhere state NEW

Re: java.lang.OutOfMemoryError: Java heap space

2013-10-21 Thread Praveen kumar s.k
You should try to utilize maximum of your RAM to map tasks. You can do that by changing the parameters at mapred-site.xml file. add the below statements to set 6.5 GB of RAM for map tasks property namemapred.map.child.java.opts/name value-Xmx6500m/value descriptionheap size for map