HBASE-9735 region_mover.rb uses the removed HConnection.getZooKeeperWatcher()
git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1530784 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
65e623415f
commit
066638e6cc
@ -88,15 +88,20 @@ end
|
|||||||
def getServerNameForRegion(admin, r)
|
def getServerNameForRegion(admin, r)
|
||||||
if r.isMetaRegion()
|
if r.isMetaRegion()
|
||||||
# Hack
|
# Hack
|
||||||
tracker = org.apache.hadoop.hbase.zookeeper.MetaRegionTracker.new(admin.getConnection().getZooKeeperWatcher(), RubyAbortable.new())
|
zkw = org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher.new(admin.getConfiguration(), "region_mover", nil)
|
||||||
tracker.start()
|
begin
|
||||||
while not tracker.isLocationAvailable()
|
tracker = org.apache.hadoop.hbase.zookeeper.MetaRegionTracker.new(zkw, RubyAbortable.new())
|
||||||
sleep 0.1
|
tracker.start()
|
||||||
|
while not tracker.isLocationAvailable()
|
||||||
|
sleep 0.1
|
||||||
|
end
|
||||||
|
# Make a fake servername by appending ','
|
||||||
|
metaServer = tracker.getMetaRegionLocation().toString() + ","
|
||||||
|
tracker.stop()
|
||||||
|
return metaServer
|
||||||
|
ensure
|
||||||
|
zkw.close()
|
||||||
end
|
end
|
||||||
# Make a fake servername by appending ','
|
|
||||||
metaServer = tracker.getMetaRegionLocation().toString() + ","
|
|
||||||
tracker.stop()
|
|
||||||
return metaServer
|
|
||||||
end
|
end
|
||||||
table = nil
|
table = nil
|
||||||
table = getMetaTable(admin.getConfiguration())
|
table = getMetaTable(admin.getConfiguration())
|
||||||
|
Loading…
x
Reference in New Issue
Block a user