From: KAUSHIK SARKAR mailto:countkaus...@gmail.com>>
Reply-To: "user@giraph.apache.org<mailto:user@giraph.apache.org>"
mailto:user@giraph.apache.org>>
Date: Tuesday, August 21, 2012 7:39 AM
To: "user@giraph.apache.org<mailto:user@giraph.apache.org&
;"
mailto:user@giraph.apache.org>>
Date: Tuesday, August 21, 2012 7:39 AM
To: "user@giraph.apache.org<mailto:user@giraph.apache.org>"
mailto:user@giraph.apache.org>>
Subject: Re: Adding MasterCompute object causes "failed to report status" errors
Hi Nick,
s...@gmail.com>>
Reply-To: "user@giraph.apache.org<mailto:user@giraph.apache.org>"
mailto:user@giraph.apache.org>>
Date: Tuesday, August 21, 2012 7:39 AM
To: "user@giraph.apache.org<mailto:user@giraph.apache.org>"
mailto:user@giraph.apache.org>>
Subject
o: "user@giraph.apache.org<mailto:user@giraph.apache.org>"
mailto:user@giraph.apache.org>>
Subject: Re: Adding MasterCompute object causes "failed to report status" errors
Hi Nick,
Please refer to the SimpleMasterComputeWorkerContext class in the attached
SimpleMas
Hi Nick,
Please refer to the SimpleMasterComputeWorkerContext class in the attached
SimpleMasterComputeVertex.java file (This is from the snapshot of 0.2 that
I am using. It is approx. 1 month old. It seems that the WorkerContext
class is different from the current svn version. I am not aware if t
I'm a little confused by the examples in SimpleMasterComputeVertex.java.
To me it looks like this is a simple example with one vertex and one aggregator
with the following behavior:
- The vertex gets the value stored in the aggregator and then adds its previous
value to it and stores the result
Hi Nick,
Are you using WorkerContext to register the aggregator? You need to
override the preApplication() method in WorkerContext to register the
aggregator and then override the preSuperstep() method to to tell the
workers to use the aggregator (the useAggregator() method). Check the
MasterCompu
Hi,
I have a giraph application that runs fine; however, when I add a MasterCompute
object (definition following) all of the map tasks time out. I have hadoop
configured to run with 8 map processes and giraph to use one worker.
Here's the definition of the MasterCompute object:
class BPMasterC
