HBASE-15022 replication_admin.rb throws undefined method `getZooKeeperClusterKey' for ZKUtil
This commit is contained in:
parent
f56abf730f
commit
9a297ef0a5
|
@ -22,7 +22,7 @@ include Java
|
||||||
java_import org.apache.hadoop.hbase.client.replication.ReplicationAdmin
|
java_import org.apache.hadoop.hbase.client.replication.ReplicationAdmin
|
||||||
java_import org.apache.hadoop.hbase.replication.ReplicationPeerConfig
|
java_import org.apache.hadoop.hbase.replication.ReplicationPeerConfig
|
||||||
java_import org.apache.hadoop.hbase.util.Bytes
|
java_import org.apache.hadoop.hbase.util.Bytes
|
||||||
java_import org.apache.hadoop.hbase.zookeeper.ZKUtil
|
java_import org.apache.hadoop.hbase.zookeeper.ZKConfig
|
||||||
java_import org.apache.hadoop.hbase.TableName
|
java_import org.apache.hadoop.hbase.TableName
|
||||||
|
|
||||||
# Wrapper for org.apache.hadoop.hbase.client.replication.ReplicationAdmin
|
# Wrapper for org.apache.hadoop.hbase.client.replication.ReplicationAdmin
|
||||||
|
@ -62,7 +62,7 @@ module Hbase
|
||||||
|
|
||||||
# Cluster Key is required for ReplicationPeerConfig for a custom replication endpoint
|
# Cluster Key is required for ReplicationPeerConfig for a custom replication endpoint
|
||||||
if !endpoint_classname.nil? and cluster_key.nil?
|
if !endpoint_classname.nil? and cluster_key.nil?
|
||||||
cluster_key = ZKUtil.getZooKeeperClusterKey(@configuration)
|
cluster_key = ZKConfig.getZooKeeperClusterKey(@configuration)
|
||||||
end
|
end
|
||||||
|
|
||||||
# Optional parameters
|
# Optional parameters
|
||||||
|
|
Loading…
Reference in New Issue