DRILL-1366: HBaseRecordReader does not set rowcount correctly if vectors run out of memory in the middle of the row.
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/7cd659d2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/7cd659d2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/7cd659d2 Branch: refs/heads/master Commit: 7cd659d24ea47c829f795832b9b9ec90dd31ae7b Parents: 749dbe4 Author: Aditya Kishore <adi...@maprtech.com> Authored: Fri Aug 29 19:36:38 2014 +0530 Committer: Jacques Nadeau <jacq...@apache.org> Committed: Fri Aug 29 23:05:56 2014 -0700 ---------------------------------------------------------------------- .../java/org/apache/drill/exec/store/hbase/HBaseRecordReader.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/7cd659d2/contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseRecordReader.java ---------------------------------------------------------------------- diff --git a/contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseRecordReader.java b/contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseRecordReader.java index ce44627..cbd5269 100644 --- a/contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseRecordReader.java +++ b/contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseRecordReader.java @@ -215,7 +215,7 @@ public class HBaseRecordReader extends AbstractRecordReader implements DrillHBas int valueLength = kv.getValueLength(); if (!v.getMutator().setSafe(rowCount, bytes, valueOffset, valueLength)) { leftOver = result; - return rowCount; + break done; } } }
