DRILL-790: In FragmentExecutor if operator tree init fails notify failure to root fragment to avoid query hangs.
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/dd650cc9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/dd650cc9 Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/dd650cc9 Branch: refs/heads/master Commit: dd650cc96f655d5c84603cf8e0ad53b4fc3c37ff Parents: 27a9c98 Author: vkorukanti <[email protected]> Authored: Tue Jun 10 10:23:47 2014 -0700 Committer: vkorukanti <[email protected]> Committed: Tue Jun 10 22:41:12 2014 -0700 ---------------------------------------------------------------------- .../java/org/apache/drill/exec/work/fragment/FragmentExecutor.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/dd650cc9/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 4474f3f..36727ec 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 @@ -81,6 +81,8 @@ public class FragmentExecutor implements Runnable, CancelableQuery, StatusProvid root = ImplCreator.getExec(context, rootOperator); } catch (ExecutionSetupException e) { context.fail(e); + logger.debug("Failure while running fragement", e); + internalFail(e); return; }
