drill-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jacq...@apache.org
Subject [2/6] drill git commit: DRILL-1812: Avoid calling stop() in SingleSender in rpc thread
Date Fri, 05 Dec 2014 18:14:17 GMT
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 <sphillips@maprtech.com>
Authored: Thu Dec 4 21:17:12 2014 -0800
Committer: Steven Phillips <sphillips@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;
       }
 
     }


Mime
View raw message