Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-13075 TableInputFormatBase spuriously warning about multiple initializeTable calls

This commit is contained in:
Sean Busbey 2015-02-19 13:59:27 -06:00
parent 18402cc850
commit 365054c110
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hbase-server/src/main/java/org/apache/hadoop/hbase/mapred/TableInputFormatBase.java
View File

@ -231,7 +231,7 @@ implements InputFormat<ImmutableBytesWritable, Result> {
* @throws IOException * @throws IOException
*/ */
protected void initializeTable(Connection connection, TableName tableName) throws IOException { protected void initializeTable(Connection connection, TableName tableName) throws IOException {
if (table != null || connection != null) { if (this.table != null || this.connection != null) {
LOG.warn("initializeTable called multiple times. Overwriting connection and table " + LOG.warn("initializeTable called multiple times. Overwriting connection and table " +
"reference; TableInputFormatBase will not close these old references when done."); "reference; TableInputFormatBase will not close these old references when done.");
} }

2
hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TableInputFormatBase.java
View File

@ -641,7 +641,7 @@ extends InputFormat<ImmutableBytesWritable, Result> {
* @throws IOException * @throws IOException
*/ */
protected void initializeTable(Connection connection, TableName tableName) throws IOException { protected void initializeTable(Connection connection, TableName tableName) throws IOException {
if (table != null || connection != null) { if (this.table != null || this.connection != null) {
LOG.warn("initializeTable called multiple times. Overwriting connection and table " + LOG.warn("initializeTable called multiple times. Overwriting connection and table " +
"reference; TableInputFormatBase will not close these old references when done."); "reference; TableInputFormatBase will not close these old references when done.");
} }