Author: edwardyoon
Date: Thu May 14 13:25:35 2015
New Revision: 1679363
URL: http://svn.apache.org/r1679363
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=1679363&r1=1679362&r2=1679363&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 13:25:35 2015
@@ -164,6 +164,7 @@ public class TestKeyValueTextInputFormat
job.setBspClass(KeyValueHashPartitionedBSP.class);
job.setBoolean(Constants.ENABLE_RUNTIME_PARTITIONING, true);
+ job.set(Constants.RUNTIME_PARTITIONING_DIR, "/tmp/hamatest/parts");
job.setPartitioner(HashPartitioner.class);
job.setNumBspTask(2);
@@ -184,6 +185,7 @@ public class TestKeyValueTextInputFormat
} finally {
// clean-up output
fs.delete(outPath, true);
+ fs.delete(new Path("/tmp/hamatest/parts"), true);
}
}
}