You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by te...@apache.org on 2014/06/28 01:28:24 UTC
git commit: HBASE-10330 TableInputFormat/TableRecordReaderImpl leaks
HTable
Repository: hbase
Updated Branches:
refs/heads/0.98 53d5702f4 -> 52967c6e7
HBASE-10330 TableInputFormat/TableRecordReaderImpl leaks HTable
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/52967c6e
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/52967c6e
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/52967c6e
Branch: refs/heads/0.98
Commit: 52967c6e74a855fc981b6901c0dd89c72a68eb69
Parents: 53d5702
Author: Ted Yu <te...@apache.org>
Authored: Fri Jun 27 23:28:09 2014 +0000
Committer: Ted Yu <te...@apache.org>
Committed: Fri Jun 27 23:28:09 2014 +0000
----------------------------------------------------------------------
.../org/apache/hadoop/hbase/mapred/TableRecordReaderImpl.java | 5 +++++
.../apache/hadoop/hbase/mapreduce/TableRecordReaderImpl.java | 5 +++++
2 files changed, 10 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/52967c6e/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 08c1873..f4043f4 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
@@ -155,6 +155,11 @@ public class TableRecordReaderImpl {
public void close() {
this.scanner.close();
+ try {
+ this.htable.close();
+ } catch (IOException ioe) {
+ LOG.warn("Error closing table", ioe);
+ }
}
/**
http://git-wip-us.apache.org/repos/asf/hbase/blob/52967c6e/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 a95055d..7eb7871 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
@@ -159,6 +159,11 @@ public class TableRecordReaderImpl {
*/
public void close() {
this.scanner.close();
+ try {
+ this.htable.close();
+ } catch (IOException ioe) {
+ LOG.warn("Error closing table", ioe);
+ }
}
/**