last commit did not pick up the actual fix for the test case-- checki…

…ng ti in
glinmac · Mar 25, 2013 · 0c05a03 · 0c05a03
1 parent d4f5935
commit 0c05a03
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/...b/hadoop-store-builder/test/voldemort/store/readonly/fetcher/HDFSFetcherAdvancedTest.java b/...b/hadoop-store-builder/test/voldemort/store/readonly/fetcher/HDFSFetcherAdvancedTest.java
@@ -44,6 +44,7 @@
 import voldemort.store.readonly.checksum.CheckSum.CheckSumType;
 import voldemort.store.readonly.checksum.CheckSumTests;
 import voldemort.store.readonly.fetcher.HdfsFetcher.CopyStats;
+import voldemort.utils.Utils;
 
 /*
  * This test suite tests the HDFSFetcher We test the fetch from hadoop by
@@ -83,20 +84,20 @@ public void testCheckSumMetadata() throws Exception {
                                                                               CheckSumType.MD5))));
         FileUtils.writeStringToFile(metadataFile, metadata.toJsonString());
 
-        File tempDest = new File(testDestinationDirectory.getAbsolutePath() + "3");
+        File tempDest = new File(testDestinationDirectory.getAbsolutePath() + "1");
         if(tempDest.exists()) {
 
             deleteDir(tempDest);
         }
 
         File fetchedFile = fetcher.fetch(testSourceDirectory.getAbsolutePath(),
-                                         testDestinationDirectory.getAbsolutePath() + "3");
+                                         testDestinationDirectory.getAbsolutePath() + "1");
 
         assertNotNull(fetchedFile);
         assertEquals(fetchedFile.getAbsolutePath(), testDestinationDirectory.getAbsolutePath()
-                                                    + "3");
+                                                    + "1");
 
-        tempDest = new File(testDestinationDirectory.getAbsolutePath() + "3");
+        tempDest = new File(testDestinationDirectory.getAbsolutePath() + "1");
         if(tempDest.exists()) {
 
             deleteDir(tempDest);
@@ -178,6 +179,7 @@ public void testEofExceptionIntermittent() throws Exception {
                                                                                           source));
 
         File destination = new File(testDestinationDirectory.getAbsolutePath() + "1");
+        Utils.mkdirs(destination);
         File copyLocation = new File(destination, "0_0.index");
 
         Mockito.doThrow(new IOException())
@@ -229,6 +231,7 @@ public void testEofExceptionIntermittentDuringFetch() throws Exception {
                                                                                           source));
 
         File destination = new File(testDestinationDirectory.getAbsolutePath() + "1");
+        Utils.mkdirs(destination);
         File copyLocation = new File(destination, "0_0.index");
 
         FSDataInputStream input = null;
@@ -286,6 +289,7 @@ public void testIntermittentRuntimeExceptions() throws Exception {
                                                                                           source));
 
         File destination = new File(testDestinationDirectory.getAbsolutePath() + "1");
+        Utils.mkdirs(destination);
         File copyLocation = new File(destination, "0_0.index");
 
         Mockito.doThrow(new RuntimeException())