You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by te...@apache.org on 2014/03/05 18:45:38 UTC
svn commit: r1574588 -
/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java
Author: tedyu
Date: Wed Mar 5 17:45:37 2014
New Revision: 1574588
URL: http://svn.apache.org/r1574588
Log:
HBASE-10670 HBaseFsck#connect() should use new connection
Modified:
hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java
Modified: hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java?rev=1574588&r1=1574587&r2=1574588&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java (original)
+++ hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java Wed Mar 5 17:45:37 2014
@@ -302,10 +302,10 @@ public class HBaseFsck extends Configure
* 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();
}
/**