ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [35/50] [abbrv] incubator-ignite git commit: [IGNITE-633]: Test HadoopMapReduceEmbeddedSelfTest.testWholeMapReduceExecution sometimes hangs
Date Thu, 11 Jun 2015 06:12:59 GMT
[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-gg-10326
Commit: 593d8620e0482befceafcf9ce8014ed9adb09326
Parents: 8018af4
Author: iveselovskiy <iveselovskiy@gridgain.com>
Authored: Wed Jun 10 15:34:03 2015 +0300
Committer: iveselovskiy <iveselovskiy@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)
-                );
+            );
         }
     }
 


Mime
View raw message