Repository: hbase Updated Branches: refs/heads/branch-1 54f5129da -> 8470936d7
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/8470936d Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/8470936d Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/8470936d Branch: refs/heads/branch-1 Commit: 8470936d763a86dca0bdd65345dee799011166fb Parents: 54f5129 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:04 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/8470936d/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 43ace95..9307667 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 @@ -179,7 +179,7 @@ public class HTable implements HTableInterface { this.connection = null; return; } - this.connection = (ClusterConnection) ConnectionFactory.createConnection(conf); + this.connection = ConnectionManager.getConnectionInternal(conf); this.configuration = conf; this.pool = getDefaultExecutor(conf); @@ -251,7 +251,7 @@ public class HTable implements HTableInterface { @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) {
