You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by sa...@apache.org on 2016/12/15 23:38:05 UTC
phoenix git commit: PHOENIX-3537 Clients not able to resolve
sequences when the SYSTEM.SEQUENCE table is salted
Repository: phoenix
Updated Branches:
refs/heads/4.9-HBase-0.98 534b100e0 -> d2fcc7a68
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/d2fcc7a6
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/d2fcc7a6
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/d2fcc7a6
Branch: refs/heads/4.9-HBase-0.98
Commit: d2fcc7a6845df1fc9cfacf64b80fea69a89fd6e6
Parents: 534b100
Author: Samarth <sa...@salesforce.com>
Authored: Thu Dec 15 15:37:56 2016 -0800
Committer: Samarth <sa...@salesforce.com>
Committed: Thu Dec 15 15:37:56 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/d2fcc7a6/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) {}