Repository: hbase Updated Branches: refs/heads/branch-1.0 30a646f77 -> 28ea3e019
HBASE-13075 TableInputFormatBase spuriously warning about multiple initializeTable calls Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/28ea3e01 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/28ea3e01 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/28ea3e01 Branch: refs/heads/branch-1.0 Commit: 28ea3e0197def97f900dc57884048c547ca94def Parents: 30a646f Author: Sean Busbey <bus...@apache.org> Authored: Thu Feb 19 13:59:27 2015 -0600 Committer: Sean Busbey <bus...@apache.org> Committed: Thu Feb 19 16:53:08 2015 -0600 ---------------------------------------------------------------------- .../java/org/apache/hadoop/hbase/mapred/TableInputFormatBase.java | 2 +- .../org/apache/hadoop/hbase/mapreduce/TableInputFormatBase.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/28ea3e01/hbase-server/src/main/java/org/apache/hadoop/hbase/mapred/TableInputFormatBase.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapred/TableInputFormatBase.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapred/TableInputFormatBase.java index da457cf..ddba8a1 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapred/TableInputFormatBase.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapred/TableInputFormatBase.java @@ -230,7 +230,7 @@ implements InputFormat<ImmutableBytesWritable, Result> { * @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 " + "reference; TableInputFormatBase will not close these old references when done."); } http://git-wip-us.apache.org/repos/asf/hbase/blob/28ea3e01/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TableInputFormatBase.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TableInputFormatBase.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TableInputFormatBase.java index 7becdb4..e83216d 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TableInputFormatBase.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TableInputFormatBase.java @@ -443,7 +443,7 @@ extends InputFormat<ImmutableBytesWritable, Result> { * @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 " + "reference; TableInputFormatBase will not close these old references when done."); }