DRILL-1476: Clear transfer pair list when in Limit when schema changes
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/37138810 Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/37138810 Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/37138810 Branch: refs/heads/master Commit: 37138810418c25dc455d5fc6c30b33cb612c4c50 Parents: d8edf63 Author: Steven Phillips <[email protected]> Authored: Tue Sep 30 18:17:23 2014 -0700 Committer: Steven Phillips <[email protected]> Committed: Tue Sep 30 18:17:23 2014 -0700 ---------------------------------------------------------------------- .../org/apache/drill/exec/physical/impl/limit/LimitRecordBatch.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/37138810/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/limit/LimitRecordBatch.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/limit/LimitRecordBatch.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/limit/LimitRecordBatch.java index 8f4d90f..8ffd7be 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/limit/LimitRecordBatch.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/limit/LimitRecordBatch.java @@ -60,6 +60,7 @@ public class LimitRecordBatch extends AbstractSingleRecordBatch<Limit> { @Override protected void setupNewSchema() throws SchemaChangeException { container.clear(); + transfers.clear(); for(VectorWrapper<?> v : incoming){
