drill-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jacq...@apache.org
Subject [05/17] git commit: Temporarily disable ProducerConsumer operator until DRILL-1202 is fixed.
Date Tue, 29 Jul 2014 15:38:17 GMT
Temporarily disable ProducerConsumer operator until DRILL-1202 is fixed.


Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/deaca5d8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/deaca5d8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/deaca5d8

Branch: refs/heads/master
Commit: deaca5d8ec81ed03b0ad6a187c16723717ba2c51
Parents: 0a603df
Author: Steven Phillips <sphillips@maprtech.com>
Authored: Sun Jul 27 17:32:21 2014 -0700
Committer: Jacques Nadeau <jacques@apache.org>
Committed: Mon Jul 28 20:21:35 2014 -0700

----------------------------------------------------------------------
 .../apache/drill/exec/planner/sql/handlers/DefaultSqlHandler.java | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/deaca5d8/exec/java-exec/src/main/java/org/apache/drill/exec/planner/sql/handlers/DefaultSqlHandler.java
----------------------------------------------------------------------
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/sql/handlers/DefaultSqlHandler.java
b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/sql/handlers/DefaultSqlHandler.java
index a3effd9..8c9b499 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/sql/handlers/DefaultSqlHandler.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/sql/handlers/DefaultSqlHandler.java
@@ -191,10 +191,13 @@ public class DefaultSqlHandler extends AbstractSqlHandler {
      * Add ProducerConsumer after each scan if the option is set
      * Use the configured queueSize
      */
+    // Disabling for now, as this causes memory leaks. See DRILL-1202
+    /*
     if (context.getOptions().getOption(PlannerSettings.PRODUCER_CONSUMER.getOptionName()).bool_val)
{
       long queueSize = context.getOptions().getOption(PlannerSettings.PRODUCER_CONSUMER_QUEUE_SIZE.getOptionName()).num_val;
       phyRelNode = ProducerConsumerPrelVisitor.addProducerConsumerToScans(phyRelNode, (int)
queueSize);
     }
+    */
 
     /* 6.)
      * if the client does not support complex types (Map, Repeated)


Mime
View raw message