From 1d790506467defa5800a1eafeaed0601808cbc31 Mon Sep 17 00:00:00 2001 From: zhangduo Date: Sat, 12 Jan 2019 14:09:52 +0800 Subject: [PATCH] HBASE-21705 Should treat meta table specially for some methods in AsyncAdmin --- .../hadoop/hbase/AsyncMetaTableAccessor.java | 6 ---- .../hbase/client/RawAsyncHBaseAdmin.java | 13 ++++++++ .../hbase/client/TestAsyncTableAdminApi3.java | 32 ++++++++++++++++--- 3 files changed, 41 insertions(+), 10 deletions(-) diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/AsyncMetaTableAccessor.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/AsyncMetaTableAccessor.java index 13245d377a..5d38179fab 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/AsyncMetaTableAccessor.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/AsyncMetaTableAccessor.java @@ -17,8 +17,6 @@ */ package org.apache.hadoop.hbase; -import static org.apache.hadoop.hbase.TableName.META_TABLE_NAME; - import java.io.IOException; import java.util.ArrayList; import java.util.Arrays; @@ -32,7 +30,6 @@ import java.util.concurrent.CompletableFuture; import java.util.regex.Matcher; import java.util.regex.Pattern; import java.util.stream.Collectors; - import org.apache.hadoop.hbase.MetaTableAccessor.CollectingVisitor; import org.apache.hadoop.hbase.MetaTableAccessor.QueryType; import org.apache.hadoop.hbase.MetaTableAccessor.Visitor; @@ -74,9 +71,6 @@ public class AsyncMetaTableAccessor { public static CompletableFuture tableExists(AsyncTable metaTable, TableName tableName) { - if (tableName.equals(META_TABLE_NAME)) { - return CompletableFuture.completedFuture(true); - } return getTableState(metaTable, tableName).thenApply(Optional::isPresent); } diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.java index 1440a647c8..08a202ba20 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.java @@ -415,6 +415,9 @@ class RawAsyncHBaseAdmin implements AsyncAdmin { @Override public CompletableFuture tableExists(TableName tableName) { + if (TableName.isMetaTableName(tableName)) { + return CompletableFuture.completedFuture(true); + } return AsyncMetaTableAccessor.tableExists(metaTable, tableName); } @@ -594,6 +597,9 @@ class RawAsyncHBaseAdmin implements AsyncAdmin { @Override public CompletableFuture isTableEnabled(TableName tableName) { + if (TableName.isMetaTableName(tableName)) { + return CompletableFuture.completedFuture(true); + } CompletableFuture future = new CompletableFuture<>(); addListener(AsyncMetaTableAccessor.getTableState(metaTable, tableName), (state, error) -> { if (error != null) { @@ -611,6 +617,9 @@ class RawAsyncHBaseAdmin implements AsyncAdmin { @Override public CompletableFuture isTableDisabled(TableName tableName) { + if (TableName.isMetaTableName(tableName)) { + return CompletableFuture.completedFuture(false); + } CompletableFuture future = new CompletableFuture<>(); addListener(AsyncMetaTableAccessor.getTableState(metaTable, tableName), (state, error) -> { if (error != null) { @@ -640,6 +649,10 @@ class RawAsyncHBaseAdmin implements AsyncAdmin { private CompletableFuture isTableAvailable(TableName tableName, Optional splitKeys) { + if (TableName.isMetaTableName(tableName)) { + return connection.registry.getMetaRegionLocation().thenApply(locs -> Stream + .of(locs.getRegionLocations()).allMatch(loc -> loc != null && loc.getServerName() != null)); + } CompletableFuture future = new CompletableFuture<>(); addListener(isTableEnabled(tableName), (enabled, error) -> { if (error != null) { diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestAsyncTableAdminApi3.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestAsyncTableAdminApi3.java index 07c8d774a5..0f6d1bbbb2 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestAsyncTableAdminApi3.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestAsyncTableAdminApi3.java @@ -18,6 +18,7 @@ package org.apache.hadoop.hbase.client; import org.apache.hadoop.hbase.AsyncMetaTableAccessor; +import org.apache.hadoop.hbase.DoNotRetryIOException; import org.apache.hadoop.hbase.HBaseClassTestRule; import org.apache.hadoop.hbase.HRegionLocation; import org.apache.hadoop.hbase.TableName; @@ -39,7 +40,8 @@ import java.util.regex.Pattern; import static org.apache.hadoop.hbase.TableName.META_TABLE_NAME; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertFalse; -import static org.junit.Assert.assertTrue; +import static org.junit.Assert.*; +import static org.hamcrest.CoreMatchers.*; /** * Class to test asynchronous table admin operations. @@ -57,12 +59,15 @@ public class TestAsyncTableAdminApi3 extends TestAsyncAdminBase { public void testTableExist() throws Exception { boolean exist; exist = admin.tableExists(tableName).get(); - assertEquals(false, exist); + assertFalse(exist); TEST_UTIL.createTable(tableName, FAMILY); exist = admin.tableExists(tableName).get(); - assertEquals(true, exist); + assertTrue(exist); exist = admin.tableExists(TableName.META_TABLE_NAME).get(); - assertEquals(true, exist); + assertTrue(exist); + // meta table already exists + exist = admin.tableExists(TableName.META_TABLE_NAME).get(); + assertTrue(exist); } @Test @@ -177,6 +182,13 @@ public class TestAsyncTableAdminApi3 extends TestAsyncAdminBase { ok = false; } assertTrue(ok); + // meta table can not be disabled. + try { + admin.disableTable(TableName.META_TABLE_NAME).get(); + } catch (ExecutionException e) { + Throwable cause = e.getCause(); + assertThat(cause, instanceOf(DoNotRetryIOException.class)); + } } @Test @@ -278,5 +290,17 @@ public class TestAsyncTableAdminApi3 extends TestAsyncAdminBase { admin.disableTable(tableName).join(); assertFalse(admin.isTableEnabled(tableName).get()); assertTrue(admin.isTableDisabled(tableName).get()); + + // meta table is always enabled + assertTrue(admin.isTableEnabled(TableName.META_TABLE_NAME).get()); + assertFalse(admin.isTableDisabled(TableName.META_TABLE_NAME).get()); + } + + @Test + public void testIsTableAvailable() throws Exception { + createTableWithDefaultConf(tableName); + TEST_UTIL.waitTableAvailable(tableName); + assertTrue(admin.isTableAvailable(tableName).get()); + assertTrue(admin.isTableAvailable(TableName.META_TABLE_NAME).get()); } } -- 2.17.1