hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From apurt...@apache.org
Subject [2/3] git commit: Replication gets stuck following a transient zookeeper error to remote peer cluster
Date Sat, 01 Nov 2014 01:04:26 GMT
Replication gets stuck following a transient zookeeper error to remote peer cluster

Signed-off-by: Andrew Purtell <apurtell@apache.org>


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 <amuraru@adobe.com>
Authored: Thu Oct 30 23:50:02 2014 +0200
Committer: Andrew Purtell <apurtell@apache.org>
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();
     }
 


Mime
View raw message