HBASE-10670 HBaseFsck#connect() should use new connection

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1574588 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Zhihong Yu 2014-03-05 17:45:37 +00:00
parent 1500ae9438
commit ddaf9b7701
1 changed files with 3 additions and 3 deletions

View File

@ -302,10 +302,10 @@ public class HBaseFsck extends Configured {
* online state. * online state.
*/ */
public void connect() throws IOException { public void connect() throws IOException {
admin = new HBaseAdmin(getConf()); connection = HConnectionManager.createConnection(getConf());
meta = new HTable(getConf(), TableName.META_TABLE_NAME); admin = new HBaseAdmin(connection);
meta = new HTable(TableName.META_TABLE_NAME, connection);
status = admin.getClusterStatus(); status = admin.getClusterStatus();
connection = admin.getConnection();
} }
/** /**