PHOENIX-3537 Clients not able to resolve sequences when the SYSTEM.SEQUENCE table is salted
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/e966e26a Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/e966e26a Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/e966e26a Branch: refs/heads/encodecolumns2 Commit: e966e26ad90ef80ee2c9a7f074d5389baa1520a7 Parents: 9b06c60 Author: Samarth <samarth.j...@salesforce.com> Authored: Thu Dec 15 15:41:20 2016 -0800 Committer: Samarth <samarth.j...@salesforce.com> Committed: Thu Dec 15 15:41:20 2016 -0800 ---------------------------------------------------------------------- .../org/apache/phoenix/query/ConnectionQueryServicesImpl.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/e966e26a/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 c8d42d9..c8cd04d 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 @@ -2461,7 +2461,9 @@ public class ConnectionQueryServicesImpl extends DelegateQueryServices implement private void createOtherSystemTables(PhoenixConnection metaConnection) throws SQLException { try { metaConnection.createStatement().execute(QueryConstants.CREATE_SEQUENCE_METADATA); - } catch (TableAlreadyExistsException ignore) {} + } catch (TableAlreadyExistsException e) { + nSequenceSaltBuckets = getSaltBuckets(e); + } try { metaConnection.createStatement().execute(QueryConstants.CREATE_STATS_TABLE_METADATA); } catch (TableAlreadyExistsException ignore) {}
