Repository: hbase Updated Branches: refs/heads/branch-1.0 144bc32e2 -> fb44b267b
HBASE-12835 HBASE-12422 changed new HTable(Configuration) to not use managed Connections anymore Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/fb44b267 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/fb44b267 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/fb44b267 Branch: refs/heads/branch-1.0 Commit: fb44b267b870ab40faa1edd1860f22081ab387c6 Parents: 144bc32 Author: Enis Soztutar <e...@apache.org> Authored: Mon Jan 12 16:21:04 2015 -0800 Committer: Enis Soztutar <e...@apache.org> Committed: Mon Jan 12 16:21:33 2015 -0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/hadoop/hbase/client/HTable.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/fb44b267/hbase-client/src/main/java/org/apache/hadoop/hbase/client/HTable.java ---------------------------------------------------------------------- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/HTable.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/HTable.java index c141b29..7c433e0 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/HTable.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/HTable.java @@ -180,7 +180,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); @@ -252,7 +252,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); + this.connection = ConnectionManager.getConnectionInternal(conf); this.configuration = conf; this.pool = pool; if (pool == null) {
