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 c3a94e3..1e55a8a 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 @@ -182,7 +182,7 @@ public class HTable implements HTableInterface, RegionLocator { this.connection = null; return; } - this.connection = ConnectionManager.getConnectionInternal(conf); + this.connection = (ClusterConnection) ConnectionFactory.createConnection(conf); this.configuration = conf; this.pool = getDefaultExecutor(conf); @@ -254,7 +254,7 @@ public class HTable implements HTableInterface, RegionLocator { @Deprecated public HTable(Configuration conf, final TableName tableName, final ExecutorService pool) throws IOException { - this.connection = ConnectionManager.getConnectionInternal(conf); + this.connection = (ClusterConnection) ConnectionFactory.createConnection(conf); this.configuration = conf; this.pool = pool; if (pool == null) {