You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@drill.apache.org by ja...@apache.org on 2014/11/12 05:11:32 UTC
[15/16] incubator-drill git commit: DRILL-1559: increment counts even
if we break out of the read loop
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 <cw...@yahoo.com>
Authored: Tue Nov 11 11:23:13 2014 -0800
Committer: Jacques Nadeau <ja...@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;