DRILL-1559: increment counts even if we break out of the read loop
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/52b729ea Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/52b729ea Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/52b729ea Branch: refs/heads/master Commit: 52b729eacde87fdd6930b99c30582accb2c99475 Parents: 968ba61 Author: Chris Westin <cwes...@yahoo.com> Authored: Tue Nov 11 11:23:13 2014 -0800 Committer: Jacques Nadeau <jacq...@apache.org> Committed: Tue Nov 11 19:27:32 2014 -0800 ---------------------------------------------------------------------- .../org/apache/drill/exec/store/parquet2/DrillParquetReader.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/52b729ea/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet2/DrillParquetReader.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet2/DrillParquetReader.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet2/DrillParquetReader.java index 6ce4e20..8b5d035 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet2/DrillParquetReader.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet2/DrillParquetReader.java @@ -195,9 +195,11 @@ public class DrillParquetReader extends AbstractRecordReader { @Override public int next() { int count = 0; - for (; count < 4000 && totalRead < recordCount; count++, totalRead++) { + while (count < 4000 && totalRead < recordCount) { recordMaterializer.setPosition(count); recordReader.read(); + count++; + totalRead++; if (count % 100 == 0) { if (getPercentFilled() > 85) { break;
