DRILL-378: Initialize overLimit field in UnlimitedRawBatchBuffer Signed-off-by: Jacques Nadeau <[email protected]>
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/7716c7e7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/7716c7e7 Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/7716c7e7 Branch: refs/heads/master Commit: 7716c7e785116ebc6a77ef0342c1de9b4e73cffa Parents: 7f7b6be Author: Steven Phillips <[email protected]> Authored: Thu Feb 13 00:37:38 2014 -0800 Committer: Jacques Nadeau <[email protected]> Committed: Mon Mar 3 23:22:17 2014 -0800 ---------------------------------------------------------------------- .../org/apache/drill/exec/work/batch/UnlimitedRawBatchBuffer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/7716c7e7/exec/java-exec/src/main/java/org/apache/drill/exec/work/batch/UnlimitedRawBatchBuffer.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/work/batch/UnlimitedRawBatchBuffer.java b/exec/java-exec/src/main/java/org/apache/drill/exec/work/batch/UnlimitedRawBatchBuffer.java index 0175bb6..97d8d34 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/work/batch/UnlimitedRawBatchBuffer.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/work/batch/UnlimitedRawBatchBuffer.java @@ -34,7 +34,7 @@ public class UnlimitedRawBatchBuffer implements RawBatchBuffer{ private volatile boolean finished = false; private int softlimit; private int startlimit; - private AtomicBoolean overlimit; + private AtomicBoolean overlimit = new AtomicBoolean(false); public UnlimitedRawBatchBuffer(FragmentContext context) { softlimit = context.getConfig().getInt(ExecConstants.INCOMING_BUFFER_SIZE);
