svn commit: r1373028 - in /hama/trunk/graph/src/main/java/org/apache/hama/graph: AbstractAggregator.java GraphJobRunner.java

[tjungblut]

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());
             }