You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mrunit.apache.org by br...@apache.org on 2013/03/03 01:09:46 UTC
git commit: MRUNIT-179: Set mapred.output.dir and mapred.input.dir in
trunk
Updated Branches:
refs/heads/trunk 526abd651 -> 38eb6f9ef
MRUNIT-179: Set mapred.output.dir and mapred.input.dir in trunk
Project: http://git-wip-us.apache.org/repos/asf/mrunit/repo
Commit: http://git-wip-us.apache.org/repos/asf/mrunit/commit/38eb6f9e
Tree: http://git-wip-us.apache.org/repos/asf/mrunit/tree/38eb6f9e
Diff: http://git-wip-us.apache.org/repos/asf/mrunit/diff/38eb6f9e
Branch: refs/heads/trunk
Commit: 38eb6f9ef6ce2653b50faa3a4fb847bcbcd90757
Parents: 526abd6
Author: Brock Noland <br...@apache.org>
Authored: Sat Mar 2 18:09:39 2013 -0600
Committer: Brock Noland <br...@apache.org>
Committed: Sat Mar 2 18:09:39 2013 -0600
----------------------------------------------------------------------
.../mapreduce/MockMapreduceOutputFormat.java | 10 ++++++----
1 files changed, 6 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/mrunit/blob/38eb6f9e/src/main/java/org/apache/hadoop/mrunit/internal/mapreduce/MockMapreduceOutputFormat.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/hadoop/mrunit/internal/mapreduce/MockMapreduceOutputFormat.java b/src/main/java/org/apache/hadoop/mrunit/internal/mapreduce/MockMapreduceOutputFormat.java
index 47a3dfd..6a82b7a 100644
--- a/src/main/java/org/apache/hadoop/mrunit/internal/mapreduce/MockMapreduceOutputFormat.java
+++ b/src/main/java/org/apache/hadoop/mrunit/internal/mapreduce/MockMapreduceOutputFormat.java
@@ -76,10 +76,12 @@ public class MockMapreduceOutputFormat<K, V> implements OutputCollectable<K, V>
if (!outputPath.mkdir()) {
throw new IOException("Failed to create output dir " + outputPath);
}
- taskAttemptContext.getConfiguration().set(FileOutputFormat.OUTDIR,
- new Path(outputPath.toString()).toString());
- taskAttemptContext.getConfiguration().set(FileInputFormat.INPUT_DIR,
- new Path((outputPath + "/*/*/*/*")).toString());
+ String output = new Path(outputPath.toString()).toString();
+ String input = new Path((outputPath + "/*/*/*/*")).toString();
+ taskAttemptContext.getConfiguration().set(FileOutputFormat.OUTDIR, output);
+ taskAttemptContext.getConfiguration().set(FileInputFormat.INPUT_DIR, input);
+ taskAttemptContext.getConfiguration().set("mapred.output.dir", output);
+ taskAttemptContext.getConfiguration().set("mapred.input.dir", input);
}
@SuppressWarnings({ "unchecked", "rawtypes" })
@Override