svn commit: r1679358 - in /hama/trunk/core/src: main/java/org/apache/hama/bsp/PartitioningRunner.java test/java/org/apache/hama/bsp/TestKeyValueTextInputFormat.java

[edwardyoon]

Author: edwardyoon
Date: Thu May 14 12:47:44 2015
New Revision: 1679358

URL: http://svn.apache.org/r1679358
Log: (empty)

Modified:
    hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java
    
hama/trunk/core/src/test/java/org/apache/hama/bsp/TestKeyValueTextInputFormat.java

Modified: 
hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java
URL: 
http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java?rev=1679358&r1=1679357&r2=1679358&view=diff
==============================================================================
--- hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java 
(original)
+++ hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java 
Thu May 14 12:47:44 2015
@@ -143,6 +143,8 @@ public class PartitioningRunner extends
 
       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);
     }
 

Modified: 
hama/trunk/core/src/test/java/org/apache/hama/bsp/TestKeyValueTextInputFormat.java
URL: 
http://svn.apache.org/viewvc/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestKeyValueTextInputFormat.java?rev=1679358&r1=1679357&r2=1679358&view=diff
==============================================================================
--- 
hama/trunk/core/src/test/java/org/apache/hama/bsp/TestKeyValueTextInputFormat.java
 (original)
+++ 
hama/trunk/core/src/test/java/org/apache/hama/bsp/TestKeyValueTextInputFormat.java
 Thu May 14 12:47:44 2015
@@ -79,7 +79,6 @@ public class TestKeyValueTextInputFormat
         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));