[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 Gupta <[email protected]> Authored: Thu Jul 6 11:44:06 2017 +0530 Committer: jackylk <[email protected]> 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);
