You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by ed...@apache.org on 2015/05/14 14:29:21 UTC
svn commit: r1679356 -
/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestKeyValueTextInputFormat.java
Author: edwardyoon
Date: Thu May 14 12:29:21 2015
New Revision: 1679356
URL: http://svn.apache.org/r1679356
Log: (empty)
Modified:
hama/trunk/core/src/test/java/org/apache/hama/bsp/TestKeyValueTextInputFormat.java
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=1679356&r1=1679355&r2=1679356&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:29:21 2015
@@ -79,23 +79,14 @@ public class TestKeyValueTextInputFormat
int expectedPeerId = Math.abs(key.hashCode() % numTasks);
if (expectedPeerId == peer.getPeerIndex()) {
- System.out.println(key + ", " + expectedPeerId + ", " + peer.getPeerIndex());
- if (expectedKeys.containsKey(key)) {
- // same key twice, incorrect
- message.put(new Text(
- KeyValueHashPartitionedBSP.TEST_UNEXPECTED_KEYS),
- new BooleanWritable(true));
- break;
- } else {
- expectedKeys.put(new Text(key), new Text(value));
- }
+ expectedKeys.put(new Text(key), new Text(value));
} else {
message.put(
new Text(KeyValueHashPartitionedBSP.TEST_UNEXPECTED_KEYS),
new BooleanWritable(true));
break;
- } // if (expectedPeerId == peer.getPeerIndex())
- } // while (peer.readNext(key, value) != false)
+ }
+ }
message.put(new Text(KeyValueHashPartitionedBSP.TEST_INPUT_VALUES),
expectedKeys);