hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From te...@apache.org
Subject hbase git commit: HBASE-17601 close() in TableRecordReaderImpl assumes the split has started (Michael Axiak)
Date Mon, 06 Feb 2017 19:02:01 GMT
Repository: hbase
Updated Branches:
  refs/heads/branch-1.2 7efa34b42 -> 9bd76426f


HBASE-17601 close() in TableRecordReaderImpl assumes the split has started (Michael Axiak)


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/9bd76426
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/9bd76426
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/9bd76426

Branch: refs/heads/branch-1.2
Commit: 9bd76426f427738438703741c0bba167757688ce
Parents: 7efa34b
Author: tedyu <yuzhihong@gmail.com>
Authored: Mon Feb 6 11:01:55 2017 -0800
Committer: tedyu <yuzhihong@gmail.com>
Committed: Mon Feb 6 11:01:55 2017 -0800

----------------------------------------------------------------------
 .../org/apache/hadoop/hbase/mapred/TableRecordReaderImpl.java    | 4 +++-
 .../org/apache/hadoop/hbase/mapreduce/TableRecordReaderImpl.java | 4 +++-
 2 files changed, 6 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/9bd76426/hbase-server/src/main/java/org/apache/hadoop/hbase/mapred/TableRecordReaderImpl.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapred/TableRecordReaderImpl.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapred/TableRecordReaderImpl.java
index 6356106..2ace8e2 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapred/TableRecordReaderImpl.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapred/TableRecordReaderImpl.java
@@ -154,7 +154,9 @@ public class TableRecordReaderImpl {
   }
 
   public void close() {
-    this.scanner.close();
+    if (this.scanner != null) {
+      this.scanner.close();
+    }
     try {
       this.htable.close();
     } catch (IOException ioe) {

http://git-wip-us.apache.org/repos/asf/hbase/blob/9bd76426/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TableRecordReaderImpl.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TableRecordReaderImpl.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TableRecordReaderImpl.java
index dcc4943..6f1d140 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TableRecordReaderImpl.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TableRecordReaderImpl.java
@@ -161,7 +161,9 @@ public class TableRecordReaderImpl {
    *
    */
   public void close() {
-    this.scanner.close();
+    if (this.scanner != null) {
+      this.scanner.close();
+    }
     try {
       this.htable.close();
     } catch (IOException ioe) {


Mime
View raw message