Replication gets stuck following a transient zookeeper error to remote peer cluster
Signed-off-by: Andrew Purtell <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/0505072c Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/0505072c Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/0505072c Branch: refs/heads/branch-1 Commit: 0505072c5182841ad1a28d798527c69bcc3348f0 Parents: e15a803 Author: Adrian Muraru <[email protected]> Authored: Thu Oct 30 23:50:02 2014 +0200 Committer: Andrew Purtell <[email protected]> Committed: Fri Oct 31 17:59:43 2014 -0700 ---------------------------------------------------------------------- .../hbase/replication/regionserver/ReplicationSinkManager.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/0505072c/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSinkManager.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSinkManager.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSinkManager.java index 2104268..b186e08 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSinkManager.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSinkManager.java @@ -106,8 +106,8 @@ public class ReplicationSinkManager { * @return a replication sink to replicate to */ public SinkPeer getReplicationSink() throws IOException { - if (endpoint.getLastRegionServerUpdate() > this.lastUpdateToPeers) { - LOG.info("Current list of sinks is out of date, updating"); + if (endpoint.getLastRegionServerUpdate() > this.lastUpdateToPeers || sinks.isEmpty()) { + LOG.info("Current list of sinks is out of date or empty, updating"); chooseSinks(); }
