diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java index 8c625b7..2453977 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java @@ -29,6 +29,7 @@ import org.apache.hadoop.hbase.client.HConnectable; import org.apache.hadoop.hbase.client.HConnection; import org.apache.hadoop.hbase.client.HConnectionManager; import org.apache.hadoop.hbase.client.HTable; +import org.apache.hadoop.hbase.client.ConnectionFactory; import org.apache.hadoop.hbase.client.Get; import org.apache.hadoop.hbase.client.Put; import org.apache.hadoop.hbase.client.Result; @@ -125,7 +126,8 @@ public class VerifyReplication extends Configured implements Tool { if (versions >= 0) { scan.setMaxVersions(versions); } - sourceTable = new HTable(conf, tableName); + TableName tableName = TableName.valueOf(conf.get(NAME + ".tableName")); + sourceTable = ConnectionFactory.createConnection(conf).getTable(tableName); final TableSplit tableSplit = (TableSplit)(context.getInputSplit()); HConnectionManager.execute(new HConnectable(conf) { @@ -211,7 +213,7 @@ public class VerifyReplication extends Configured implements Tool { } } if (sourceTable != null) { - TableName tableName = replicatedTable.getName(); + TableName tableName = sourceTable.getName(); try { sourceTable.close(); } catch (IOException ioe) {