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 2015/12/03 02:07:20 UTC
[3/4] drill git commit: Accidently reverted last change.
Accidently reverted last change.
Project: http://git-wip-us.apache.org/repos/asf/drill/repo
Commit: http://git-wip-us.apache.org/repos/asf/drill/commit/33e3f1aa
Tree: http://git-wip-us.apache.org/repos/asf/drill/tree/33e3f1aa
Diff: http://git-wip-us.apache.org/repos/asf/drill/diff/33e3f1aa
Branch: refs/heads/master
Commit: 33e3f1aa91b03ff751c9973e0e0b29e78bf43b5b
Parents: 42bf845
Author: Amit Hadke <am...@gmail.com>
Authored: Wed Dec 2 13:36:34 2015 -0800
Committer: Amit Hadke <am...@gmail.com>
Committed: Wed Dec 2 16:47:32 2015 -0800
----------------------------------------------------------------------
.../src/main/java/org/apache/drill/exec/record/RecordIterator.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/drill/blob/33e3f1aa/exec/java-exec/src/main/java/org/apache/drill/exec/record/RecordIterator.java
----------------------------------------------------------------------
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/record/RecordIterator.java b/exec/java-exec/src/main/java/org/apache/drill/exec/record/RecordIterator.java
index 408514c..77cb9a1 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/record/RecordIterator.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/record/RecordIterator.java
@@ -93,7 +93,7 @@ public class RecordIterator implements VectorAccessible {
// Release all batches before current batch. [0 to startBatchPosition).
final Map<Range<Long>,RecordBatchData> oldBatches = batches.subRangeMap(Range.closedOpen(0l, startBatchPosition)).asMapOfRanges();
for (Range<Long> range : oldBatches.keySet()) {
- oldBatches.get(range.lowerEndpoint()).clear();
+ oldBatches.get(range).clear();
}
batches.remove(Range.closedOpen(0l, startBatchPosition));
markedInnerPosition = innerPosition;