commit a9b5888080b85faa00dc010002f2cd3cabced3c2
author Edward J. Yoon <edwardyoon@apache.org> Thu May 14 12:47:44 2015 +0000
committer Edward J. Yoon <edwardyoon@apache.org> Thu May 14 12:47:44 2015 +0000
tree 3d4b04d3613cdadd9acf269dec732668d801b752
parent b75792a72903b57b832a88bed7384d2d8087a89a

git-svn-id: https://svn.apache.org/repos/asf/hama/trunk@1679358 13f79535-47bb-0310-9956-ffa450edef68

core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java

diff --git a/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java b/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java
index 05d87e2..64ba941 100644
--- a/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java
+++ b/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java
@@ -143,6 +143,8 @@
 
       raw = new MapWritable();
       raw.put(rawRecord.getKey(), rawRecord.getValue());
+      
+      System.out.println(peer.getPeerName(index) + ", " + rawRecord.getKey() + ", " + rawRecord.getValue());
       peer.send(peer.getPeerName(index), raw);
     }
 

core/src/test/java/org/apache/hama/bsp/TestKeyValueTextInputFormat.java

diff --git a/core/src/test/java/org/apache/hama/bsp/TestKeyValueTextInputFormat.java b/core/src/test/java/org/apache/hama/bsp/TestKeyValueTextInputFormat.java
index 98e2fad..495fa74 100644
--- a/core/src/test/java/org/apache/hama/bsp/TestKeyValueTextInputFormat.java
+++ b/core/src/test/java/org/apache/hama/bsp/TestKeyValueTextInputFormat.java
@@ -79,7 +79,6 @@
         int expectedPeerId = Math.abs(key.hashCode() % numTasks);
 
         System.out.println(peer.getPeerName() + ": " + key + ", " + value + ", " + expectedPeerId);
-        
         /*
         if (expectedPeerId == peer.getPeerIndex()) {
           expectedKeys.put(new Text(key), new Text(value));