diff --git hbase-client/src/main/java/org/apache/hadoop/hbase/client/HTable.java hbase-client/src/main/java/org/apache/hadoop/hbase/client/HTable.java index a9eb01c..b9548d0 100644 --- hbase-client/src/main/java/org/apache/hadoop/hbase/client/HTable.java +++ hbase-client/src/main/java/org/apache/hadoop/hbase/client/HTable.java @@ -178,7 +178,7 @@ public class HTable implements HTableInterface, RegionLocator { this.connection = null; return; } - this.connection = (ClusterConnection) ConnectionFactory.createConnection(conf); + this.connection = ConnectionManager.getConnectionInternal(conf); this.configuration = conf; this.pool = getDefaultExecutor(conf); @@ -250,7 +250,7 @@ public class HTable implements HTableInterface, RegionLocator { @Deprecated public HTable(Configuration conf, final TableName tableName, final ExecutorService pool) throws IOException { - this.connection = (ClusterConnection) ConnectionFactory.createConnection(conf); + ConnectionManager.getConnectionInternal(conf); this.configuration = conf; this.pool = pool; if (pool == null) {