Repository: incubator-drill Updated Branches: refs/heads/master af7f91767 -> cdd2ce905
clear sv2 in FilterBatch when new schema Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/b4bdc37f Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/b4bdc37f Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/b4bdc37f Branch: refs/heads/master Commit: b4bdc37fed20f279169616c69020d69ad734ac0f Parents: d08b8b8 Author: Steven Phillips <[email protected]> Authored: Thu May 15 15:12:57 2014 -0700 Committer: Steven Phillips <[email protected]> Committed: Thu May 15 15:13:11 2014 -0700 ---------------------------------------------------------------------- .../apache/drill/exec/physical/impl/filter/FilterRecordBatch.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/b4bdc37f/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/filter/FilterRecordBatch.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/filter/FilterRecordBatch.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/filter/FilterRecordBatch.java index 566dfe0..fb0e03b 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/filter/FilterRecordBatch.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/filter/FilterRecordBatch.java @@ -96,6 +96,9 @@ public class FilterRecordBatch extends AbstractSingleRecordBatch<Filter>{ @Override protected void setupNewSchema() throws SchemaChangeException { container.clear(); + if (sv2 != null) { + sv2.clear(); + } switch(incoming.getSchema().getSelectionVectorMode()){ case NONE:
