From 666490a0b8f30c1f1ba6c1db975c77c828ff67b2 Mon Sep 17 00:00:00 2001 From: Ashu Pachauri Date: Thu, 15 Oct 2015 11:58:33 -0700 Subject: [PATCH] HBASE-14621: ReplicationLogCleaner stuck on RS crash. --- .../apache/hadoop/hbase/replication/master/ReplicationLogCleaner.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/master/ReplicationLogCleaner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/master/ReplicationLogCleaner.java index 474f497..a6b6dd8 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/master/ReplicationLogCleaner.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/master/ReplicationLogCleaner.java @@ -95,8 +95,8 @@ public class ReplicationLogCleaner extends BaseLogCleanerDelegate implements Abo * not be included. */ private Set loadWALsFromQueues() throws KeeperException { - int v0 = replicationQueues.getQueuesZNodeCversion(); for (int retry = 0; ; retry++) { + int v0 = replicationQueues.getQueuesZNodeCversion(); List rss = replicationQueues.getListOfReplicators(); if (rss == null) { LOG.debug("Didn't find any region server that replicates, won't prevent any deletions."); -- 1.9.5