From 3dd353aedbfffcc28a13647c8c2367d48309cf27 Mon Sep 17 00:00:00 2001 From: Jean-Daniel Cryans Date: Thu, 7 Apr 2011 23:23:48 +0000 Subject: [PATCH] HBASE-3734 HBaseAdmin creates new configurations in getCatalogTracker git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1090061 13f79535-47bb-0310-9956-ffa450edef68 --- CHANGES.txt | 1 + .../hadoop/hbase/client/HBaseAdmin.java | 25 +++++++++---------- 2 files changed, 13 insertions(+), 13 deletions(-) diff --git a/CHANGES.txt b/CHANGES.txt index e0de83fd8d8..f9939a93d0b 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -178,6 +178,7 @@ Release 0.90.3 - Unreleased BUG FIXES HBASE-3746 Clean up CompressionTest to not directly reference DistributedFileSystem (todd) + HBASE-3734 HBaseAdmin creates new configurations in getCatalogTracker IMPROVEMENTS diff --git a/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java b/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java index e022fe4bd94..afb666a8357 100644 --- a/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java +++ b/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java @@ -75,17 +75,17 @@ public class HBaseAdmin implements Abortable { /** * Constructor * - * @param conf Configuration object + * @param c Configuration object * @throws MasterNotRunningException if the master is not running * @throws ZooKeeperConnectionException if unable to connect to zookeeper */ - public HBaseAdmin(Configuration conf) + public HBaseAdmin(Configuration c) throws MasterNotRunningException, ZooKeeperConnectionException { - this.connection = HConnectionManager.getConnection(conf); - this.conf = conf; - this.pause = conf.getLong("hbase.client.pause", 1000); - this.numRetries = conf.getInt("hbase.client.retries.number", 10); - this.retryLongerMultiplier = conf.getInt("hbase.client.retries.longer.multiplier", 10); + this.conf = HBaseConfiguration.create(c); + this.connection = HConnectionManager.getConnection(this.conf); + this.pause = this.conf.getLong("hbase.client.pause", 1000); + this.numRetries = this.conf.getInt("hbase.client.retries.number", 10); + this.retryLongerMultiplier = this.conf.getInt("hbase.client.retries.longer.multiplier", 10); this.connection.getMaster(); } @@ -101,7 +101,7 @@ public class HBaseAdmin implements Abortable { CatalogTracker ct = null; try { HConnection connection = - HConnectionManager.getConnection(new Configuration(this.conf)); + HConnectionManager.getConnection(this.conf); ct = new CatalogTracker(connection); ct.start(); } catch (InterruptedException e) { @@ -114,7 +114,6 @@ public class HBaseAdmin implements Abortable { private void cleanupCatalogTracker(final CatalogTracker ct) { ct.stop(); - HConnectionManager.deleteConnection(ct.getConnection().getConfiguration(), true); } @Override @@ -822,7 +821,7 @@ public class HBaseAdmin implements Abortable { try { if (isRegionName) { Pair pair = - MetaReader.getRegion(getCatalogTracker(), tableNameOrRegionName); + MetaReader.getRegion(ct, tableNameOrRegionName); if (pair == null || pair.getSecond() == null) { LOG.info("No server in .META. for " + Bytes.toString(tableNameOrRegionName) + "; pair=" + pair); @@ -831,7 +830,7 @@ public class HBaseAdmin implements Abortable { } } else { List> pairs = - MetaReader.getTableRegionsAndLocations(getCatalogTracker(), + MetaReader.getTableRegionsAndLocations(ct, Bytes.toString(tableNameOrRegionName)); for (Pair pair: pairs) { if (pair.getFirst().isOffline()) continue; @@ -1079,7 +1078,7 @@ public class HBaseAdmin implements Abortable { if (isRegionName(tableNameOrRegionName)) { // Its a possible region name. Pair pair = - MetaReader.getRegion(getCatalogTracker(), tableNameOrRegionName); + MetaReader.getRegion(ct, tableNameOrRegionName); if (pair == null || pair.getSecond() == null) { LOG.info("No server in .META. for " + Bytes.toString(tableNameOrRegionName) + "; pair=" + pair); @@ -1088,7 +1087,7 @@ public class HBaseAdmin implements Abortable { } } else { List> pairs = - MetaReader.getTableRegionsAndLocations(getCatalogTracker(), + MetaReader.getTableRegionsAndLocations(ct, Bytes.toString(tableNameOrRegionName)); for (Pair pair: pairs) { // May not be a server for a particular row