You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@drill.apache.org by sm...@apache.org on 2014/10/01 05:19:31 UTC
[2/3] git commit: DRILL-1476: Clear transfer pair list when in Limit
when schema changes
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/smp-merge-140929c
Commit: 37138810418c25dc455d5fc6c30b33cb612c4c50
Parents: d8edf63
Author: Steven Phillips <sp...@maprtech.com>
Authored: Tue Sep 30 18:17:23 2014 -0700
Committer: Steven Phillips <sp...@maprtech.com>
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){