Repository: incubator-drill Updated Branches: refs/heads/master 8573ba12c -> 786096659
DRILL-1617: Disable ProducerConsumer Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/78609665 Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/78609665 Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/78609665 Branch: refs/heads/master Commit: 78609665930a14aff131c7ce47713e3a37b0339b Parents: 8573ba1 Author: Steven Phillips <[email protected]> Authored: Thu Oct 30 14:38:43 2014 -0700 Committer: Steven Phillips <[email protected]> Committed: Thu Oct 30 14:38:43 2014 -0700 ---------------------------------------------------------------------- .../apache/drill/exec/planner/sql/handlers/DefaultSqlHandler.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/78609665/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 ca444a3..5f91e6e 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 @@ -230,10 +230,12 @@ public class DefaultSqlHandler extends AbstractSqlHandler { * Add ProducerConsumer after each scan if the option is set * Use the configured queueSize */ + /* DRILL-1617 Disabling ProducerConsumer as it produces incorrect results 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.)
