Dear Matthew,
Yes my aggregator is commutative, and I want globally aggregated value from all
workers, and not the locally aggregated.
But I am getting locally aggregated value.
My query is :
Does Giraph call the aggregator class for the values returned by the local
aggregators or not?
-
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
