hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tjungb...@apache.org
Subject svn commit: r1373736 - /hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java
Date Thu, 16 Aug 2012 05:33:41 GMT
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());



Mime
View raw message