Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-20054 removes the indefinite retry introduced by HBASE-18282

This commit is contained in:
tedyu 2018-02-23 19:14:04 -08:00
parent 4ddfdaffdc
commit d6d1e49a75
1 changed files with 5 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.java
View File

@ -782,20 +782,11 @@ public class ReplicationSourceManager implements ReplicationListener {
@Override @Override
public void run() { public void run() {
List<String> currentReplicators = null; List<String> currentReplicators = null;
while (currentReplicators == null) {
try { try {
currentReplicators = replicationQueues.getListOfReplicators(); currentReplicators = replicationQueues.getListOfReplicators();
} catch (ReplicationException e1) { } catch (ReplicationException e) {
LOG.warn("Failure in getListOfReplicators(), will retry later", e1); server.abort("Failed to get all replicators", e);
try { return;
Thread.sleep(ThreadLocalRandom.current().nextInt(10000));
} catch (InterruptedException e2) {
LOG.warn("Interrupted while waiting for list of replicators to be available, "
+ "will not adopt any abandoned queues", e2);
Thread.currentThread().interrupt();
break;
}
}
} }
if (currentReplicators == null || currentReplicators.isEmpty()) { if (currentReplicators == null || currentReplicators.isEmpty()) {
return; return;