You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by td...@apache.org on 2016/02/08 23:42:14 UTC
phoenix git commit: PHOENIX-2655 In MetadataClient creatTableInternal
if NEWER_TABLE_FOUND swallow NewerTableAlreadyExistsException if the
ifNotExists flag is true
Repository: phoenix
Updated Branches:
refs/heads/master e5e9144f4 -> 1c3a86d31
PHOENIX-2655 In MetadataClient creatTableInternal if NEWER_TABLE_FOUND swallow NewerTableAlreadyExistsException if the ifNotExists flag is true
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/1c3a86d3
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/1c3a86d3
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/1c3a86d3
Branch: refs/heads/master
Commit: 1c3a86d3139804c5c2e8a51a8e02bd3ecbd59515
Parents: e5e9144
Author: Thomas D'Silva <td...@salesforce.com>
Authored: Mon Feb 8 13:29:55 2016 -0800
Committer: Thomas D'Silva <td...@salesforce.com>
Committed: Mon Feb 8 14:38:47 2016 -0800
----------------------------------------------------------------------
.../src/main/java/org/apache/phoenix/schema/MetaDataClient.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/phoenix/blob/1c3a86d3/phoenix-core/src/main/java/org/apache/phoenix/schema/MetaDataClient.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/schema/MetaDataClient.java b/phoenix-core/src/main/java/org/apache/phoenix/schema/MetaDataClient.java
index ac2062a..0456335 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/MetaDataClient.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/MetaDataClient.java
@@ -2158,7 +2158,9 @@ public class MetaDataClient {
case NEWER_TABLE_FOUND:
// Add table to ConnectionQueryServices so it's cached, but don't add
// it to this connection as we can't see it.
- throw new NewerTableAlreadyExistsException(schemaName, tableName, result.getTable());
+ if (!statement.ifNotExists()) {
+ throw new NewerTableAlreadyExistsException(schemaName, tableName, result.getTable());
+ }
case UNALLOWED_TABLE_MUTATION:
throw new SQLExceptionInfo.Builder(SQLExceptionCode.CANNOT_MUTATE_TABLE)
.setSchemaName(schemaName).setTableName(tableName).build().buildException();