giraph-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Panagiotis Eustratiadis <>
Subject Persistent aggregator resets value to 0 after each superstep
Date Fri, 22 May 2015 13:46:55 GMT
Hello everyone,

A little while ago, there was this thread Puneet started:

Unfortunately, it is not helping me. What I encounter is this:

I have a custom MasterCompute class that overrides the initialize method as

public void initialize() throws InstantiationException,
IllegalAccessException {

where COMPUTATION_PHASE_AGGREGATOR is a String constant. Then, inside the
compute method of my MasterCompute class I change the value of this
aggregator with the statement:

if (getSuperstep() == 0) {
    setAggregatedValue(COMPUTATION_PHASE_AGGREGATOR, new IntWritable(-1));

As a result, in the following supersteps I expect the value of this
aggregator to be -1. But when I print the value using a logger, it's 0. I
experimented a bit, calling the setAggregatedValue() method in many places,
and I came to the conclusion that after each superstep it resets to 0.
Which does not make sense to me, because of the whole point of a persistent

I am using giraph v1.1.0-hadoop2. I appreciate any help.
Panagiotis Eustratiadis.

View raw message