mrunit-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dbe...@apache.org
Subject svn commit: r1371389 - in /mrunit/trunk/src/test/java/org/apache/hadoop/mrunit: TestDistributedCache.java mapreduce/TestDistributedCache.java
Date Thu, 09 Aug 2012 19:15:47 GMT
Author: dbeech
Date: Thu Aug  9 19:15:46 2012
New Revision: 1371389

URL: http://svn.apache.org/viewvc?rev=1371389&view=rev
Log:
MRUNIT-98: DistributedCache support. Fixing unit tests - order of outputs is unimportant

Modified:
    mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestDistributedCache.java
    mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestDistributedCache.java

Modified: mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestDistributedCache.java
URL: http://svn.apache.org/viewvc/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestDistributedCache.java?rev=1371389&r1=1371388&r2=1371389&view=diff
==============================================================================
--- mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestDistributedCache.java (original)
+++ mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestDistributedCache.java Thu Aug
 9 19:15:46 2012
@@ -142,7 +142,7 @@ public class TestDistributedCache {
   public void testAddCacheFileToMapperUsingDriverMethod() throws IOException
   {
     mapDriver.withCacheFile("testfile")
-      .withOutput(new Text("testfile"), new Text("file")).runTest();
+      .withOutput(new Text("testfile"), new Text("file")).runTest(false);
   }
 
   @Test
@@ -151,7 +151,7 @@ public class TestDistributedCache {
     Configuration conf = new Configuration();
     DistributedCache.addCacheFile(new File("README.txt").toURI(), conf);
     mapDriver.withConfiguration(conf)
-      .withOutput(new Text("README.txt"), new Text("file")).runTest();
+      .withOutput(new Text("README.txt"), new Text("file")).runTest(false);
   }
 
   @Test
@@ -165,7 +165,7 @@ public class TestDistributedCache {
       .withOutput(new Text("testarchive.tar/b"), new Text("file"))
       .withOutput(new Text("testarchive.tar/c"), new Text("file"))
       .withOutput(new Text("testarchive.tar/d"), new Text("file"))
-      .runTest();
+      .runTest(false);
   }
 
   @Test
@@ -175,14 +175,14 @@ public class TestDistributedCache {
     // through without being expanded
     mapDriver.withCacheArchive("testarchive.tar.abc")
       .withOutput(new Text("testarchive.tar.abc"), new Text("file"))
-      .runTest();
+      .runTest(false);
   }
 
   @Test
   public void testAddCacheFileToReducerUsingDriverMethod() throws IOException
   {
     reduceDriver.withCacheFile("testfile")
-      .withOutput(new Text("testfile"), new Text("file")).runTest();
+      .withOutput(new Text("testfile"), new Text("file")).runTest(false);
   }
   
   @Test
@@ -191,7 +191,7 @@ public class TestDistributedCache {
     Configuration conf = new Configuration();
     DistributedCache.addCacheFile(new File("README.txt").toURI(), conf);
     reduceDriver.withConfiguration(conf)
-      .withOutput(new Text("README.txt"), new Text("file")).runTest();
+      .withOutput(new Text("README.txt"), new Text("file")).runTest(false);
   }
 
   @Test
@@ -203,7 +203,7 @@ public class TestDistributedCache {
       .withOutput(new Text("testarchive.tar/b"), new Text("file"))
       .withOutput(new Text("testarchive.tar/c"), new Text("file"))
       .withOutput(new Text("testarchive.tar/d"), new Text("file"))
-      .runTest();
+      .runTest(false);
   }
 
   @Test
@@ -219,7 +219,7 @@ public class TestDistributedCache {
       .withOutput(new Text("testarchive.tar/b"), new Text("file"))
       .withOutput(new Text("testarchive.tar/c"), new Text("file"))
       .withOutput(new Text("testarchive.tar/d"), new Text("file"))
-      .runTest();
+      .runTest(false);
   }
   
   @Test
@@ -235,7 +235,7 @@ public class TestDistributedCache {
       .withOutput(new Text("testarchive.tar/b"), new Text("file"))
       .withOutput(new Text("testarchive.tar/c"), new Text("file"))
       .withOutput(new Text("testarchive.tar/d"), new Text("file"))
-      .runTest();
+      .runTest(false);
   }
 
 }

Modified: mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestDistributedCache.java
URL: http://svn.apache.org/viewvc/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestDistributedCache.java?rev=1371389&r1=1371388&r2=1371389&view=diff
==============================================================================
--- mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestDistributedCache.java
(original)
+++ mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestDistributedCache.java
Thu Aug  9 19:15:46 2012
@@ -157,7 +157,7 @@ public class TestDistributedCache {
   public void testAddCacheFileToMapperUsingDriverMethod() throws IOException
   {
     mapDriver.withCacheFile("testfile")
-      .withOutput(new Text("testfile"), new Text("file")).runTest();
+      .withOutput(new Text("testfile"), new Text("file")).runTest(false);
   }
 
   @Test
@@ -166,7 +166,7 @@ public class TestDistributedCache {
     Configuration conf = new Configuration();
     DistributedCache.addCacheFile(new File("README.txt").toURI(), conf);
     mapDriver.withConfiguration(conf)
-      .withOutput(new Text("README.txt"), new Text("file")).runTest();
+      .withOutput(new Text("README.txt"), new Text("file")).runTest(false);
   }
 
   @Test
@@ -180,7 +180,7 @@ public class TestDistributedCache {
       .withOutput(new Text("testarchive.tar/b"), new Text("file"))
       .withOutput(new Text("testarchive.tar/c"), new Text("file"))
       .withOutput(new Text("testarchive.tar/d"), new Text("file"))
-      .runTest();
+      .runTest(false);
   }
 
   @Test
@@ -190,14 +190,14 @@ public class TestDistributedCache {
     // through without being expanded
     mapDriver.withCacheArchive("testarchive.tar.abc")
       .withOutput(new Text("testarchive.tar.abc"), new Text("file"))
-      .runTest();
+      .runTest(false);
   }
 
   @Test
   public void testAddCacheFileToReducerUsingDriverMethod() throws IOException
   {
     reduceDriver.withCacheFile("testfile")
-      .withOutput(new Text("testfile"), new Text("file")).runTest();
+      .withOutput(new Text("testfile"), new Text("file")).runTest(false);
   }
   
   @Test
@@ -206,7 +206,7 @@ public class TestDistributedCache {
     Configuration conf = new Configuration();
     DistributedCache.addCacheFile(new File("README.txt").toURI(), conf);
     reduceDriver.withConfiguration(conf)
-      .withOutput(new Text("README.txt"), new Text("file")).runTest();
+      .withOutput(new Text("README.txt"), new Text("file")).runTest(false);
   }
 
   @Test
@@ -218,7 +218,7 @@ public class TestDistributedCache {
       .withOutput(new Text("testarchive.tar/b"), new Text("file"))
       .withOutput(new Text("testarchive.tar/c"), new Text("file"))
       .withOutput(new Text("testarchive.tar/d"), new Text("file"))
-      .runTest();
+      .runTest(false);
   }
 
   @Test
@@ -234,7 +234,7 @@ public class TestDistributedCache {
       .withOutput(new Text("testarchive.tar/b"), new Text("file"))
       .withOutput(new Text("testarchive.tar/c"), new Text("file"))
       .withOutput(new Text("testarchive.tar/d"), new Text("file"))
-      .runTest();
+      .runTest(false);
   }
   
   @Test
@@ -250,7 +250,7 @@ public class TestDistributedCache {
       .withOutput(new Text("testarchive.tar/b"), new Text("file"))
       .withOutput(new Text("testarchive.tar/c"), new Text("file"))
       .withOutput(new Text("testarchive.tar/d"), new Text("file"))
-      .runTest();
+      .runTest(false);
   }
 
 }



Mime
View raw message