Repository: phoenix Updated Branches: refs/heads/4.8-HBase-0.98 1c1a564e8 -> 55cf908bd
PHOENIX-3652 Users who do not have global access to hbase cluster can't connect to phoenix(addendum) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/55cf908b Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/55cf908b Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/55cf908b Branch: refs/heads/4.8-HBase-0.98 Commit: 55cf908bdcf546f741ba61db3becc63cf2539905 Parents: 1c1a564 Author: Ankit Singhal <ankitsingha...@gmail.com> Authored: Mon Feb 6 22:45:58 2017 +0530 Committer: Ankit Singhal <ankitsingha...@gmail.com> Committed: Mon Feb 6 22:45:58 2017 +0530 ---------------------------------------------------------------------- .../apache/phoenix/query/ConnectionQueryServicesImpl.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/55cf908b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java index 0d2cefa..0ebf2e2 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java @@ -2729,8 +2729,8 @@ public class ConnectionQueryServicesImpl extends DelegateQueryServices implement HTableInterface metatable = null; try (HBaseAdmin admin = getAdmin()) { ensureNamespaceCreated(QueryConstants.SYSTEM_SCHEMA_NAME); - List<TableName> tableNames = Arrays - .asList(admin.listTableNamesByNamespace(QueryConstants.SYSTEM_SCHEMA_NAME)); + List<String> tableNames = Arrays + .asList(admin.getTableNames(QueryConstants.SYSTEM_SCHEMA_NAME + "\\..*")); if (tableNames.size() == 0) { return; } if (tableNames.size() > 4) { throw new IllegalArgumentException( "Expected 4 system table only but found " + tableNames.size() + ":" + tableNames); } @@ -2748,10 +2748,10 @@ public class ConnectionQueryServicesImpl extends DelegateQueryServices implement } tableNames.remove(PhoenixDatabaseMetaData.SYSTEM_CATALOG_NAME); } - for (TableName table : tableNames) { - UpgradeUtil.mapTableToNamespace(admin, metatable, table.getNameAsString(), props, null, PTableType.SYSTEM, + for (String table : tableNames) { + UpgradeUtil.mapTableToNamespace(admin, metatable, table, props, null, PTableType.SYSTEM, null); - ConnectionQueryServicesImpl.this.removeTable(null, table.getNameAsString(), null, + ConnectionQueryServicesImpl.this.removeTable(null, table, null, MetaDataProtocol.MIN_SYSTEM_TABLE_TIMESTAMP_4_1_0); } if (!tableNames.isEmpty()) {
