diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java index c501dde..40d1ce2 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java @@ -303,10 +303,10 @@ public class HBaseFsck extends Configured { * online state. */ public void connect() throws IOException { - admin = new HBaseAdmin(getConf()); - meta = new HTable(getConf(), TableName.META_TABLE_NAME); + connection = HConnectionManager.createConnection(getConf()); + admin = new HBaseAdmin(connection); + meta = new HTable(TableName.META_TABLE_NAME, connection); status = admin.getClusterStatus(); - connection = admin.getConnection(); } /**