DRILL-1635: Additional fix for validation exceptions.
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/108d29fc Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/108d29fc Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/108d29fc Branch: refs/heads/master Commit: 108d29fce3d8465d619d45db5f6f433ca3d97619 Parents: d072f5a Author: Jacques Nadeau <jacq...@apache.org> Authored: Thu Nov 13 18:32:47 2014 -0800 Committer: Jacques Nadeau <jacq...@apache.org> Committed: Thu Nov 13 18:32:47 2014 -0800 ---------------------------------------------------------------------- .../main/java/org/apache/drill/exec/work/foreman/Foreman.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/108d29fc/exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/Foreman.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/Foreman.java b/exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/Foreman.java index 4d56173..e47c0be 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/Foreman.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/Foreman.java @@ -23,6 +23,8 @@ import java.io.Closeable; import java.io.IOException; import java.util.concurrent.TimeUnit; +import net.hydromatic.optiq.tools.ValidationException; + import org.apache.drill.common.config.DrillConfig; import org.apache.drill.common.logical.LogicalPlan; import org.apache.drill.common.logical.PlanProperties.Generator.ResultMode; @@ -385,6 +387,8 @@ public class Foreman implements Runnable, Closeable, Comparable<Object>{ runPhysicalPlan(plan); } catch (SqlParseException ex) { fail("Failure while parsing sql : " + ex.getMessage(), ex); + } catch (ValidationException ex) { + fail("Failure while validating sql : " + ex.getMessage(), ex); } catch(Exception e) { fail("Failure while running sql.", e); }
