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/07/29 17:38:17 UTC
[05/17] git commit: Temporarily disable ProducerConsumer operator
until DRILL-1202 is fixed.
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 <sp...@maprtech.com>
Authored: Sun Jul 27 17:32:21 2014 -0700
Committer: Jacques Nadeau <ja...@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)