You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by jx...@apache.org on 2012/08/23 22:26:26 UTC
svn commit: r1376680 -
/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java
Author: jxiang
Date: Thu Aug 23 20:26:26 2012
New Revision: 1376680
URL: http://svn.apache.org/viewvc?rev=1376680&view=rev
Log:
HBASE-6644 HBaseAdmin.createTable should wait more till table is enabled.
Modified:
hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java
Modified: hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java?rev=1376680&r1=1376679&r2=1376680&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java (original)
+++ hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java Thu Aug 23 20:26:26 2012
@@ -451,10 +451,17 @@ public class HBaseAdmin implements Abort
}
} else {
doneWithMetaScan = true;
+ tries = -1;
}
- }
- if (doneWithMetaScan && isTableEnabled(desc.getName())) {
+ } else if (isTableEnabled(desc.getName())) {
return;
+ } else {
+ try { // Sleep
+ Thread.sleep(getPauseTime(tries));
+ } catch (InterruptedException e) {
+ throw new InterruptedIOException("Interrupted when waiting" +
+ " for table to be enabled; meta scan was done");
+ }
}
}
throw new TableNotEnabledException(