diff options
| author | Steven Phillips <sphillips@maprtech.com> | 2014-07-27 17:32:21 -0700 |
|---|---|---|
| committer | Jacques Nadeau <jacques@apache.org> | 2014-07-28 20:21:35 -0700 |
| commit | deaca5d8ec81ed03b0ad6a187c16723717ba2c51 (patch) | |
| tree | b2720ca11cdc2680210a155557dfe9f28ea873ef /exec/java-exec/src/main | |
| parent | 0a603df36f53cf7a8d6025745cafd3f30843b5be (diff) | |
Temporarily disable ProducerConsumer operator until DRILL-1202 is fixed.
Diffstat (limited to 'exec/java-exec/src/main')
| -rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/planner/sql/handlers/DefaultSqlHandler.java | 3 |
1 files changed, 3 insertions, 0 deletions
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 a3effd91b..8c9b499e5 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) |