diff --git a/phoenix-core-client/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java b/phoenix-core-client/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java index 2d9a12865b3..a6ce4067d3d 100644 --- a/phoenix-core-client/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java +++ b/phoenix-core-client/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java @@ -2183,7 +2183,8 @@ private MetaDataMutationResult metaDataCoprocessorExec(String tableName, byte[] long startTime = EnvironmentEdgeManager.currentTimeMillis(); while (true) { if (retried) { - connection.getRegionLocator(SchemaUtil.getPhysicalName(systemTableName, this.getProps())) + connection.getRegionLocator(SchemaUtil.getPhysicalName( + systemTableName, this.getProps())) .getRegionLocation(tableKey, true); } diff --git a/phoenix-core-client/src/main/java/org/apache/phoenix/schema/MetaDataClient.java b/phoenix-core-client/src/main/java/org/apache/phoenix/schema/MetaDataClient.java index 1591e92484e..56a67df869f 100644 --- a/phoenix-core-client/src/main/java/org/apache/phoenix/schema/MetaDataClient.java +++ b/phoenix-core-client/src/main/java/org/apache/phoenix/schema/MetaDataClient.java @@ -6524,15 +6524,20 @@ public MutationState changePermissions(ChangePermsStatement changePermsStatement return new MutationState(0, 0, connection); } - private void changePermsOnSchema(org.apache.hadoop.hbase.client.Connection hConnection, ChangePermsStatement changePermsStatement) throws Throwable { + private void changePermsOnSchema(org.apache.hadoop.hbase.client.Connection hConnection, + ChangePermsStatement changePermsStatement) throws Throwable { if (changePermsStatement.isGrantStatement()) { - AccessControlClient.grant(hConnection, changePermsStatement.getSchemaName(), changePermsStatement.getName(), changePermsStatement.getPermsList()); + AccessControlClient.grant(hConnection, changePermsStatement.getSchemaName(), + changePermsStatement.getName(), changePermsStatement.getPermsList()); } else { - AccessControlClient.revoke(hConnection, changePermsStatement.getSchemaName(), changePermsStatement.getName(), Permission.Action.values()); + AccessControlClient.revoke(hConnection, changePermsStatement.getSchemaName(), + changePermsStatement.getName(), Permission.Action.values()); } } - private void changePermsOnTables(org.apache.hadoop.hbase.client.Connection hConnection, Admin admin, ChangePermsStatement changePermsStatement, PTable inputTable) throws Throwable { + private void changePermsOnTables(org.apache.hadoop.hbase.client.Connection hConnection, + Admin admin, ChangePermsStatement changePermsStatement, + PTable inputTable) throws Throwable { org.apache.hadoop.hbase.TableName tableName = SchemaUtil.getPhysicalTableName (inputTable.getPhysicalName().getBytes(), inputTable.isNamespaceMapped()); @@ -6587,7 +6592,9 @@ private void changePermsOnTables(org.apache.hadoop.hbase.client.Connection hConn } } - private void changePermsOnTable(org.apache.hadoop.hbase.client.Connection hConnection, ChangePermsStatement changePermsStatement, org.apache.hadoop.hbase.TableName tableName) + private void changePermsOnTable(org.apache.hadoop.hbase.client.Connection hConnection, + ChangePermsStatement changePermsStatement, + org.apache.hadoop.hbase.TableName tableName) throws Throwable { if (changePermsStatement.isGrantStatement()) { AccessControlClient.grant(hConnection, tableName, changePermsStatement.getName(), @@ -6598,12 +6605,15 @@ private void changePermsOnTable(org.apache.hadoop.hbase.client.Connection hConne } } - private void changePermsOnUser(org.apache.hadoop.hbase.client.Connection hConnection, ChangePermsStatement changePermsStatement) + private void changePermsOnUser(org.apache.hadoop.hbase.client.Connection hConnection, + ChangePermsStatement changePermsStatement) throws Throwable { if (changePermsStatement.isGrantStatement()) { - AccessControlClient.grant(hConnection, changePermsStatement.getName(), changePermsStatement.getPermsList()); + AccessControlClient.grant(hConnection, changePermsStatement.getName(), + changePermsStatement.getPermsList()); } else { - AccessControlClient.revoke(hConnection, changePermsStatement.getName(), Permission.Action.values()); + AccessControlClient.revoke(hConnection, changePermsStatement.getName(), + Permission.Action.values()); } } }