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 <sphill...@maprtech.com> Authored: Sun Jul 27 17:32:21 2014 -0700 Committer: Jacques Nadeau <jacq...@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)
