commit | b0e290d35ccdb669fe6df812c789af501ea8bdae | [log] [tgz] |
---|---|---|
author | Dave Beech <dbeech@apache.org> | Wed Aug 01 08:28:02 2012 +0000 |
committer | Dave Beech <dbeech@apache.org> | Wed Aug 01 08:28:02 2012 +0000 |
tree | 39a21b39c5dc740714f0adb6d19844aa195bb834 | |
parent | f747c39b748c0c7cb7501258248e946c66f27aea [diff] |
Removed dupe runTest method from PipelineMapReduceDriver. Also gets rid of wrapped IOException (MRUNIT-123) git-svn-id: https://svn.apache.org/repos/asf/mrunit/trunk@1367882 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/src/main/java/org/apache/hadoop/mrunit/PipelineMapReduceDriver.java b/src/main/java/org/apache/hadoop/mrunit/PipelineMapReduceDriver.java index be797a4..377de35 100644 --- a/src/main/java/org/apache/hadoop/mrunit/PipelineMapReduceDriver.java +++ b/src/main/java/org/apache/hadoop/mrunit/PipelineMapReduceDriver.java
@@ -368,18 +368,6 @@ return (List) inputs; } - @Override - public void runTest(final boolean orderMatters) { - try { - final List<Pair<K2, V2>> outputs = run(); - validate(outputs, orderMatters); - validate(counterWrapper); - } catch (final IOException ioe) { - LOG.error(ioe); - throw new RuntimeException(ioe); - } - } - /** * @param configuration * The configuration object that will given to the mappers and