Repository: incubator-ignite Updated Branches: refs/heads/ignite-484-1 a7229dcba -> d8825fd71
[IGNITE-633]: Test HadoopMapReduceEmbeddedSelfTest.testWholeMapReduceExecution sometimes hangs Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/593d8620 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/593d8620 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/593d8620 Branch: refs/heads/ignite-484-1 Commit: 593d8620e0482befceafcf9ce8014ed9adb09326 Parents: 8018af4 Author: iveselovskiy <iveselovs...@gridgain.com> Authored: Wed Jun 10 15:34:03 2015 +0300 Committer: iveselovskiy <iveselovs...@gridgain.com> Committed: Wed Jun 10 15:34:03 2015 +0300 ---------------------------------------------------------------------- .../processors/hadoop/HadoopMapReduceTest.java | 21 ++++++++++++-------- 1 file changed, 13 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/593d8620/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/HadoopMapReduceTest.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/HadoopMapReduceTest.java b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/HadoopMapReduceTest.java index a1ef7ba..66c14b5 100644 --- a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/HadoopMapReduceTest.java +++ b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/HadoopMapReduceTest.java @@ -132,9 +132,14 @@ public class HadoopMapReduceTest extends HadoopAbstractWordCountTest { IgfsPath inFile = new IgfsPath(inDir, HadoopWordCount2.class.getSimpleName() + "-input"); - generateTestFile(inFile.toString(), "red", 100000, "blue", 200000, "green", 150000, "yellow", 70000 ); + final int red = 10_000; + final int blue = 20_000; + final int green = 15_000; + final int yellow = 7_000; - for (int i = 0; i < 8; i++) { + generateTestFile(inFile.toString(), "red", red, "blue", blue, "green", green, "yellow", yellow ); + + for (int i = 0; i < 3; i++) { igfs.delete(new IgfsPath(PATH_OUTPUT), true); boolean useNewMapper = (i & 1) == 0; @@ -185,13 +190,13 @@ public class HadoopMapReduceTest extends HadoopAbstractWordCountTest { checkOwner(new IgfsPath(outFile)); assertEquals("Use new mapper: " + useNewMapper + ", new combiner: " + useNewCombiner + ", new reducer: " + - useNewReducer, - "blue\t200000\n" + - "green\t150000\n" + - "red\t100000\n" + - "yellow\t70000\n", + useNewReducer, + "blue\t" + blue + "\n" + + "green\t" + green + "\n" + + "red\t" + red + "\n" + + "yellow\t" + yellow + "\n", readAndSortFile(outFile) - ); + ); } }
