This is an automated email from the ASF dual-hosted git repository. arina pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/drill.git
commit 9ffd6d933cdd16e10a5818991dd80ab3c36cf88f Author: Arina Ielchiieva <arina.yelchiy...@gmail.com> AuthorDate: Mon Apr 8 10:32:11 2019 +0300 DRILL-7157: Wrap SchemaParsingException into UserException when creating schema closes #1740 --- .../org/apache/drill/exec/planner/sql/handlers/SchemaHandler.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/sql/handlers/SchemaHandler.java b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/sql/handlers/SchemaHandler.java index f1f7353..4e7c8ae 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/sql/handlers/SchemaHandler.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/sql/handlers/SchemaHandler.java @@ -35,6 +35,7 @@ import org.apache.drill.exec.record.metadata.schema.FsMetastoreSchemaProvider; import org.apache.drill.exec.record.metadata.schema.PathSchemaProvider; import org.apache.drill.exec.record.metadata.schema.SchemaContainer; import org.apache.drill.exec.record.metadata.schema.SchemaProvider; +import org.apache.drill.exec.record.metadata.schema.parser.SchemaParsingException; import org.apache.drill.exec.store.AbstractSchema; import org.apache.drill.exec.store.StorageStrategy; import org.apache.drill.exec.store.dfs.WorkspaceSchemaFactory; @@ -133,7 +134,11 @@ public abstract class SchemaHandler extends DefaultSqlHandler { ExecConstants.PERSISTENT_TABLE_UMASK).string_val, false); schemaProvider.store(schemaString, sqlCall.getProperties(), storageStrategy); return DirectPlan.createDirectPlan(context, true, String.format("Created schema for [%s]", schemaSource)); - + } catch (SchemaParsingException e) { + throw UserException.parseError(e) + .message(e.getMessage()) + .addContext("Schema: " + schemaString) + .build(logger); } catch (IOException e) { throw UserException.resourceError(e) .message(e.getMessage())