fd2f3d1abdcb79b0fc037ff92e65459660c5b502 - hbase

commit	fd2f3d1abdcb79b0fc037ff92e65459660c5b502	[log] [tgz]
author	XinSun <ddupgs@gmail.com>	Thu Aug 12 17:14:35 2021 +0800
committer	GitHub <noreply@github.com>	Thu Aug 12 17:14:35 2021 +0800
tree	6444615412d32e2e0b3dc71411d9ff97f0e25ad1
parent	add13ab6072484fcdda248ed082a4f9cdace6d1a [diff]

HBASE-26084 Add owner of replication queue for ReplicationQueueInfo (#3477)

Signed-off-by: stack <stack@apple.com>

hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/ReplicationQueueInfo.java[diff]
hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/ReplicationUtils.java[diff]
hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/ZKReplicationQueueStorage.java[diff]
hbase-server/src/main/java/org/apache/hadoop/hbase/master/replication/ReplicationPeerManager.java[diff]
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/HReplicationServer.java[diff]
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/DumpReplicationQueues.java[diff]
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/RecoveredReplicationSource.java[diff]
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java[diff]
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceFactory.java[diff]
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.java[diff]
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.java[diff]
hbase-server/src/main/java/org/apache/hadoop/hbase/util/hbck/ReplicationChecker.java[diff]
hbase-server/src/test/java/org/apache/hadoop/hbase/replication/ReplicationSourceDummy.java[diff]
hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSource.java[diff]
hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.java[diff]
hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManagerZkImpl.java[diff]

16 files changed