Kill incoming batch when limit is met
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/70cd6af5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/70cd6af5 Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/70cd6af5 Branch: refs/heads/master Commit: 70cd6af563bb90fa21f62ed055ce8335a3db60be Parents: 2b7fd5a Author: Timothy Chen <[email protected]> Authored: Tue Oct 15 09:28:53 2013 -0700 Committer: Timothy Chen <[email protected]> Committed: Tue Oct 15 09:28:53 2013 -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/70cd6af5/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 783980b..8390997 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 @@ -82,6 +82,7 @@ public class LimitRecordBatch extends AbstractSingleRecordBatch<Limit> { @Override public IterOutcome next() { if(!noEndLimit && recordsLeft <= 0) { + killIncoming(); return IterOutcome.NONE; }
