[prev in list] [next in list] [prev in thread] [next in thread] 

List:       drill-commits
Subject:    [10/15] git commit: DRILL-1366: HBaseRecordReader does not set rowcount correctly if vectors run out
From:       jacques () apache ! org
Date:       2014-08-31 17:28:09
Message-ID: 63e2d3465d4048c490fe35f785eb50d3 () git ! apache ! org
[Download RAW message or body]

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 <aditya@maprtech.com>
Authored: Fri Aug 29 19:36:38 2014 +0530
Committer: Jacques Nadeau <jacques@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;
         }
       }
     }


[prev in list] [next in list] [prev in thread] [next in thread]