Enable FragmentExecutor to catch assertion errors and return to client.
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/3f21451e Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/3f21451e Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/3f21451e Branch: refs/heads/master Commit: 3f21451e9cb9d9303afc933a7767a1c774234991 Parents: e62c365 Author: Jacques Nadeau <[email protected]> Authored: Thu Jun 5 09:36:21 2014 -0700 Committer: Jacques Nadeau <[email protected]> Committed: Thu Jun 5 09:36:21 2014 -0700 ---------------------------------------------------------------------- .../java/org/apache/drill/exec/work/fragment/FragmentExecutor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/3f21451e/exec/java-exec/src/main/java/org/apache/drill/exec/work/fragment/FragmentExecutor.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/work/fragment/FragmentExecutor.java b/exec/java-exec/src/main/java/org/apache/drill/exec/work/fragment/FragmentExecutor.java index 11685c0..4474f3f 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/work/fragment/FragmentExecutor.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/work/fragment/FragmentExecutor.java @@ -113,7 +113,7 @@ public class FragmentExecutor implements Runnable, CancelableQuery, StatusProvid closed = true; context.close(); - }catch(Exception ex){ + }catch(AssertionError | Exception ex){ logger.debug("Caught exception while running fragment", ex); internalFail(ex); }finally{
