svn commit: r1373736 - /hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java

[tjungblut]

Author: tjungblut
Date: Thu Aug 16 05:33:40 2012
New Revision: 1373736

URL: http://svn.apache.org/viewvc?rev=1373736&view=rev
Log:
additional debug output to find the problem

Modified:
    hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java

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=1373736&r1=1373735&r2=1373736&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 
Thu Aug 16 05:33:40 2012
@@ -365,7 +365,11 @@ 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("_________ " + index + " / " + e.getKey() + " / "
+                  + e.getValue());
+              LOG.info("_________+ "
+                  + (masterAggregator == null ? "NULL! " : " ")
+                  + isMasterTask(peer) + " " + peer.getPeerName());
               LOG.info("_________++ " + masterAggregator[index]);
               ((AbstractAggregator<M, Vertex<V, E, M>>) 
masterAggregator[index])
                   .addTimesAggregated(((IntWritable) e.getValue()).get());