You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@drill.apache.org by ja...@apache.org on 2014/12/05 19:14:17 UTC
[2/6] drill git commit: DRILL-1812: Avoid calling stop() in
SingleSender in rpc thread
DRILL-1812: Avoid calling stop() in SingleSender in rpc thread
Project: http://git-wip-us.apache.org/repos/asf/drill/repo
Commit: http://git-wip-us.apache.org/repos/asf/drill/commit/d15ba121
Tree: http://git-wip-us.apache.org/repos/asf/drill/tree/d15ba121
Diff: http://git-wip-us.apache.org/repos/asf/drill/diff/d15ba121
Branch: refs/heads/master
Commit: d15ba1210fc0fcb01832080cb57b78f56497c5e8
Parents: 4a4f54a
Author: Steven Phillips <sp...@maprtech.com>
Authored: Thu Dec 4 21:17:12 2014 -0800
Committer: Steven Phillips <sp...@maprtech.com>
Committed: Thu Dec 4 21:17:12 2014 -0800
----------------------------------------------------------------------
.../org/apache/drill/exec/physical/impl/SingleSenderCreator.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/drill/blob/d15ba121/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/SingleSenderCreator.java
----------------------------------------------------------------------
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/SingleSenderCreator.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/SingleSenderCreator.java
index bd4ccd0..6db9f4a 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/SingleSenderCreator.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/SingleSenderCreator.java
@@ -159,7 +159,7 @@ public class SingleSenderCreator implements RootCreator<SingleSender>{
if (!context.isCancelled() && !context.isFailed()) {
context.fail(ex);
}
- stop();
+ done = true;
}
@Override
@@ -172,7 +172,7 @@ public class SingleSenderCreator implements RootCreator<SingleSender>{
logger.error("Downstream fragment was not accepted. Stopping future sends.");
// if we didn't get ack ok, we'll need to kill the query.
context.fail(new RpcException("A downstream fragment batch wasn't accepted. This fragment thus fails."));
- stop();
+ done = true;
}
}