Repository: incubator-drill Updated Branches: refs/heads/master 807c4766a -> fdcedf972
DRILL-1596: Build schema for producer-consumer Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/81e93259 Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/81e93259 Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/81e93259 Branch: refs/heads/master Commit: 81e93259a566f3d0c9f80d54f5b49b3c84d92b09 Parents: 807c476 Author: Steven Phillips <sphill...@maprtech.com> Authored: Mon Oct 27 23:29:36 2014 -0700 Committer: Steven Phillips <sphill...@maprtech.com> Committed: Tue Oct 28 16:40:39 2014 -0700 ---------------------------------------------------------------------- .../drill/exec/physical/impl/producer/ProducerConsumerBatch.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/81e93259/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/producer/ProducerConsumerBatch.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/producer/ProducerConsumerBatch.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/producer/ProducerConsumerBatch.java index 3d991ff..132c41e 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/producer/ProducerConsumerBatch.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/producer/ProducerConsumerBatch.java @@ -78,6 +78,7 @@ public class ProducerConsumerBatch extends AbstractRecordBatch { } finally { stats.stopProcessing(); } + container.buildSchema(incoming.getSchema().getSelectionVectorMode()); return IterOutcome.OK_NEW_SCHEMA; }
