You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2013/08/23 17:40:12 UTC

svn commit: r1516897 - /hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/migration/TestNamespaceUpgrade.java

Author: stack
Date: Fri Aug 23 15:40:12 2013
New Revision: 1516897

URL: http://svn.apache.org/r1516897
Log:
HBASE-9320 Up timeouts on NamespaceUpgrades timeouts

Modified:
    hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/migration/TestNamespaceUpgrade.java

Modified: hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/migration/TestNamespaceUpgrade.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/migration/TestNamespaceUpgrade.java?rev=1516897&r1=1516896&r2=1516897&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/migration/TestNamespaceUpgrade.java (original)
+++ hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/migration/TestNamespaceUpgrade.java Fri Aug 23 15:40:12 2013
@@ -184,7 +184,7 @@ public class TestNamespaceUpgrade {
     TEST_UTIL.shutdownMiniCluster();
   }
 
-  @Test
+  @Test (timeout=300000)
   public void testSnapshots() throws IOException, InterruptedException {
     String snapshots[][] = {snapshot1Keys, snapshot2Keys};
     for(int i = 1; i <= snapshots.length; i++) {
@@ -203,7 +203,7 @@ public class TestNamespaceUpgrade {
     }
   }
 
-  @Test
+  @Test (timeout=300000)
   public void testRenameUsingSnapshots() throws Exception {
     String newNS = "newNS";
     TEST_UTIL.getHBaseAdmin().createNamespace(NamespaceDescriptor.create(newNS).build());
@@ -227,7 +227,7 @@ public class TestNamespaceUpgrade {
       Assert.assertEquals(newTableName, currentKeys.length, count);
       TEST_UTIL.getHBaseAdmin().flush(newTableName);
       TEST_UTIL.getHBaseAdmin().majorCompact(newTableName);
-      TEST_UTIL.waitFor(2000, new Waiter.Predicate<IOException>() {
+      TEST_UTIL.waitFor(30000, new Waiter.Predicate<IOException>() {
         @Override
         public boolean evaluate() throws IOException {
           try {
@@ -258,7 +258,7 @@ public class TestNamespaceUpgrade {
     }
   }
 
-  @Test
+  @Test (timeout=300000)
   public void testOldDirsAreGonePostMigration() throws IOException {
     FileSystem fs = FileSystem.get(TEST_UTIL.getConfiguration());
     Path hbaseRootDir = TEST_UTIL.getDefaultRootDirPath();
@@ -272,7 +272,7 @@ public class TestNamespaceUpgrade {
     }
   }
 
-  @Test
+  @Test (timeout=300000)
   public void testNewDirsArePresentPostMigration() throws IOException {
     FileSystem fs = FileSystem.get(TEST_UTIL.getConfiguration());
     // Below list does not include 'corrupt' because there is no 'corrupt' in the tgz
@@ -283,4 +283,4 @@ public class TestNamespaceUpgrade {
       assertTrue(dir, fs.exists(new Path(hbaseRootDir, dir)));
     }
   }
-}
+}
\ No newline at end of file