You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by sy...@apache.org on 2017/03/16 17:12:34 UTC
[06/14] hbase git commit: HBASE-17779 disable_table_replication
returns misleading message and does not turn off replication (Janos Gub)
HBASE-17779 disable_table_replication returns misleading message and does not turn off replication (Janos Gub)
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/777fea55
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/777fea55
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/777fea55
Branch: refs/heads/hbase-12439
Commit: 777fea552eab3262e95053b2fc757fc49dfad96d
Parents: 44b2558
Author: tedyu <yu...@gmail.com>
Authored: Tue Mar 14 12:13:34 2017 -0700
Committer: tedyu <yu...@gmail.com>
Committed: Tue Mar 14 12:13:34 2017 -0700
----------------------------------------------------------------------
.../apache/hadoop/hbase/client/HBaseAdmin.java | 35 +++++++++++++++-----
.../TestReplicationAdminWithClusters.java | 17 ++++++++++
2 files changed, 44 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/777fea55/hbase-client/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java
----------------------------------------------------------------------
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java
index 1f143b5..6918184 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java
@@ -4228,14 +4228,16 @@ public class HBaseAdmin implements Admin {
/**
* Set the table's replication switch if the table's replication switch is already not set.
* @param tableName name of the table
- * @param isRepEnabled is replication switch enable or disable
+ * @param enableRep is replication switch enable or disable
* @throws IOException if a remote or network exception occurs
*/
- private void setTableRep(final TableName tableName, boolean isRepEnabled) throws IOException {
+ private void setTableRep(final TableName tableName, boolean enableRep) throws IOException {
HTableDescriptor htd = getTableDescriptor(tableName);
- if (isTableRepEnabled(htd) ^ isRepEnabled) {
+ ReplicationState currentReplicationState = getTableReplicationState(htd);
+ if (enableRep && currentReplicationState != ReplicationState.ENABLED
+ || !enableRep && currentReplicationState != ReplicationState.DISABLED) {
for (HColumnDescriptor hcd : htd.getFamilies()) {
- hcd.setScope(isRepEnabled ? HConstants.REPLICATION_SCOPE_GLOBAL
+ hcd.setScope(enableRep ? HConstants.REPLICATION_SCOPE_GLOBAL
: HConstants.REPLICATION_SCOPE_LOCAL);
}
modifyTable(tableName, htd);
@@ -4243,17 +4245,34 @@ public class HBaseAdmin implements Admin {
}
/**
+ * This enum indicates the current state of the replication for a given table.
+ */
+ private enum ReplicationState {
+ ENABLED, // all column families enabled
+ MIXED, // some column families enabled, some disabled
+ DISABLED // all column families disabled
+ }
+
+ /**
* @param htd table descriptor details for the table to check
- * @return true if table's replication switch is enabled
+ * @return ReplicationState the current state of the table.
*/
- private boolean isTableRepEnabled(HTableDescriptor htd) {
+ private ReplicationState getTableReplicationState(HTableDescriptor htd) {
+ boolean hasEnabled = false;
+ boolean hasDisabled = false;
+
for (HColumnDescriptor hcd : htd.getFamilies()) {
if (hcd.getScope() != HConstants.REPLICATION_SCOPE_GLOBAL
&& hcd.getScope() != HConstants.REPLICATION_SCOPE_SERIAL) {
- return false;
+ hasDisabled = true;
+ } else {
+ hasEnabled = true;
}
}
- return true;
+
+ if (hasEnabled && hasDisabled) return ReplicationState.MIXED;
+ if (hasEnabled) return ReplicationState.ENABLED;
+ return ReplicationState.DISABLED;
}
/**
http://git-wip-us.apache.org/repos/asf/hbase/blob/777fea55/hbase-server/src/test/java/org/apache/hadoop/hbase/client/replication/TestReplicationAdminWithClusters.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/replication/TestReplicationAdminWithClusters.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/replication/TestReplicationAdminWithClusters.java
index b44ecbf..312a90a 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/replication/TestReplicationAdminWithClusters.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/replication/TestReplicationAdminWithClusters.java
@@ -76,6 +76,23 @@ public class TestReplicationAdminWithClusters extends TestReplicationBase {
}
@Test(timeout = 300000)
+ public void disableNotFullReplication() throws Exception {
+ HTableDescriptor table = admin2.getTableDescriptor(tableName);
+ HColumnDescriptor f = new HColumnDescriptor("notReplicatedFamily");
+ table.addFamily(f);
+ admin1.disableTable(tableName);
+ admin1.modifyTable(tableName, table);
+ admin1.enableTable(tableName);
+
+
+ admin1.disableTableReplication(tableName);
+ table = admin1.getTableDescriptor(tableName);
+ for (HColumnDescriptor fam : table.getColumnFamilies()) {
+ assertEquals(fam.getScope(), HConstants.REPLICATION_SCOPE_LOCAL);
+ }
+ }
+
+ @Test(timeout = 300000)
public void testEnableReplicationWhenSlaveClusterDoesntHaveTable() throws Exception {
admin1.disableTableReplication(tableName);
admin2.disableTable(tableName);