[13/24] carbondata git commit: [CARBONDATA-1269][PRESTO] Fixed bug for select operation in non existing database
[CARBONDATA-1269][PRESTO] Fixed bug for select operation in non existing database This closes #1143 Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/c7e7f70b Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/c7e7f70b Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/c7e7f70b Branch: refs/heads/streaming_ingest Commit: c7e7f70b827aba3fbd3aab849cc2a50257627cd5 Parents: 92d1d97 Author: Geetika GuptaAuthored: Thu Jul 6 11:44:06 2017 +0530 Committer: jackylk Committed: Fri Jul 7 08:41:16 2017 +0800 -- .../main/java/org/apache/carbondata/presto/CarbondataMetadata.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/carbondata/blob/c7e7f70b/integration/presto/src/main/java/org/apache/carbondata/presto/CarbondataMetadata.java -- diff --git a/integration/presto/src/main/java/org/apache/carbondata/presto/CarbondataMetadata.java b/integration/presto/src/main/java/org/apache/carbondata/presto/CarbondataMetadata.java index f2d19cf..a132fb4 100755 --- a/integration/presto/src/main/java/org/apache/carbondata/presto/CarbondataMetadata.java +++ b/integration/presto/src/main/java/org/apache/carbondata/presto/CarbondataMetadata.java @@ -111,7 +111,7 @@ public class CarbondataMetadata implements ConnectorMetadata { private ConnectorTableMetadata getTableMetadata(SchemaTableName schemaTableName) { if (!listSchemaNamesInternal().contains(schemaTableName.getSchemaName())) { - return null; + throw new SchemaNotFoundException(schemaTableName.getSchemaName()); } CarbonTable carbonTable = carbonTableReader.getTable(schemaTableName);
carbondata git commit: [CARBONDATA-1269][PRESTO] Fixed bug for select operation in non existing database
Repository: carbondata Updated Branches: refs/heads/master 92d1d970a -> c7e7f70b8 [CARBONDATA-1269][PRESTO] Fixed bug for select operation in non existing database This closes #1143 Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/c7e7f70b Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/c7e7f70b Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/c7e7f70b Branch: refs/heads/master Commit: c7e7f70b827aba3fbd3aab849cc2a50257627cd5 Parents: 92d1d97 Author: Geetika GuptaAuthored: Thu Jul 6 11:44:06 2017 +0530 Committer: jackylk Committed: Fri Jul 7 08:41:16 2017 +0800 -- .../main/java/org/apache/carbondata/presto/CarbondataMetadata.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/carbondata/blob/c7e7f70b/integration/presto/src/main/java/org/apache/carbondata/presto/CarbondataMetadata.java -- diff --git a/integration/presto/src/main/java/org/apache/carbondata/presto/CarbondataMetadata.java b/integration/presto/src/main/java/org/apache/carbondata/presto/CarbondataMetadata.java index f2d19cf..a132fb4 100755 --- a/integration/presto/src/main/java/org/apache/carbondata/presto/CarbondataMetadata.java +++ b/integration/presto/src/main/java/org/apache/carbondata/presto/CarbondataMetadata.java @@ -111,7 +111,7 @@ public class CarbondataMetadata implements ConnectorMetadata { private ConnectorTableMetadata getTableMetadata(SchemaTableName schemaTableName) { if (!listSchemaNamesInternal().contains(schemaTableName.getSchemaName())) { - return null; + throw new SchemaNotFoundException(schemaTableName.getSchemaName()); } CarbonTable carbonTable = carbonTableReader.getTable(schemaTableName);