You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by tj...@apache.org on 2012/08/14 20:56:04 UTC
svn commit: r1373028 - in
/hama/trunk/graph/src/main/java/org/apache/hama/graph:
AbstractAggregator.java GraphJobRunner.java
Author: tjungblut
Date: Tue Aug 14 18:56:03 2012
New Revision: 1373028
URL: http://svn.apache.org/viewvc?rev=1373028&view=rev
Log:
debugging for the hudson
Modified:
hama/trunk/graph/src/main/java/org/apache/hama/graph/AbstractAggregator.java
hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java
Modified: hama/trunk/graph/src/main/java/org/apache/hama/graph/AbstractAggregator.java
URL: http://svn.apache.org/viewvc/hama/trunk/graph/src/main/java/org/apache/hama/graph/AbstractAggregator.java?rev=1373028&r1=1373027&r2=1373028&view=diff
==============================================================================
--- hama/trunk/graph/src/main/java/org/apache/hama/graph/AbstractAggregator.java (original)
+++ hama/trunk/graph/src/main/java/org/apache/hama/graph/AbstractAggregator.java Tue Aug 14 18:56:03 2012
@@ -87,5 +87,10 @@ public abstract class AbstractAggregator
public IntWritable getTimesAggregated() {
return new IntWritable(timesAggregated);
}
+
+ @Override
+ public String toString() {
+ return "VAL=" + getValue();
+ }
}
Modified: hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java
URL: http://svn.apache.org/viewvc/hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java?rev=1373028&r1=1373027&r2=1373028&view=diff
==============================================================================
--- hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java (original)
+++ hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java Tue Aug 14 18:56:03 2012
@@ -365,6 +365,8 @@ public final class GraphJobRunner<V exte
&& vertexID.toString().startsWith(S_FLAG_AGGREGATOR_INCREMENT)) {
int index = Integer.parseInt(vertexID.toString().split(";")[1]);
if (isAbstractAggregator[index]) {
+ LOG.info("_________ " + index + " / " + e.getKey() + " / " + e.getValue());
+ LOG.info("_________++ " + masterAggregator[index]);
((AbstractAggregator<M, Vertex<V, E, M>>) masterAggregator[index])
.addTimesAggregated(((IntWritable) e.getValue()).get());
}