diff --git a/hbase-shell/src/main/ruby/hbase/replication_admin.rb b/hbase-shell/src/main/ruby/hbase/replication_admin.rb index f80c547..3ab8d35 100644 --- a/hbase-shell/src/main/ruby/hbase/replication_admin.rb +++ b/hbase-shell/src/main/ruby/hbase/replication_admin.rb @@ -221,12 +221,18 @@ module Hbase rpc = get_peer_config(id) unless rpc.nil? ns_set = rpc.getNamespaces - ns_set = java.util.HashSet.new if ns_set.nil? + ns_set2 = java.util.HashSet.new + unless ns_set.nil? + ns_set.each do |n| + ns_set2.add(n) + end + end namespaces.each do |n| - ns_set.add(n) + ns_set2.add(n) end - rpc.setNamespaces(ns_set) - @admin.updateReplicationPeerConfig(id, rpc) + builder = org.apache.hadoop.hbase.replication.ReplicationPeerConfig.newBuilder(rpc) + builder.setNamespaces(ns_set2) + @admin.updateReplicationPeerConfig(id, builder.build) end end end @@ -237,13 +243,15 @@ module Hbase rpc = get_peer_config(id) unless rpc.nil? ns_set = rpc.getNamespaces + ns_set2 = java.util.HashSet.new unless ns_set.nil? - namespaces.each do |n| - ns_set.remove(n) + ns_set.each do |n| + ns_set2.add(n) if !namespaces.include? n end end - rpc.setNamespaces(ns_set) - @admin.updateReplicationPeerConfig(id, rpc) + builder = org.apache.hadoop.hbase.replication.ReplicationPeerConfig.newBuilder(rpc) + builder.setNamespaces(ns_set2) + @admin.updateReplicationPeerConfig(id, builder.build) end end end @@ -354,6 +362,7 @@ module Hbase # Create and populate a ReplicationPeerConfig replication_peer_config = get_peer_config(id) unless config.nil? + builder = org.apache.hadoop.hbase.replication.ReplicationPeerConfig.newBuilder(rpc) replication_peer_config.get_configuration.put_all(config) end