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 08c1873dbaa..f4043f4836f 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); + } } /** 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 a95055dbbe2..7eb7871d3af 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); + } } /**