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

HBASE-17639 Do not stop server if ReplicationSourceManager's waitUntilCanBePushed throws InterruptedException

This commit is contained in:
Phil Yang 2017-02-13 19:03:27 +08:00
parent d7c304573f
commit 0a25bf5b3f
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
View File

@ -762,9 +762,12 @@ public class ReplicationSource extends Thread
if (!canSkipWaitingSet.getUnchecked(key)) { if (!canSkipWaitingSet.getUnchecked(key)) {
try { try {
manager.waitUntilCanBePushed(Bytes.toBytes(key), seq, actualPeerId); manager.waitUntilCanBePushed(Bytes.toBytes(key), seq, actualPeerId);
} catch (Exception e) { } catch (IOException e) {
LOG.error("waitUntilCanBePushed fail", e); LOG.error("waitUntilCanBePushed fail", e);
stopper.stop("waitUntilCanBePushed fail"); stopper.stop("waitUntilCanBePushed fail");
} catch (InterruptedException e) {
LOG.warn("waitUntilCanBePushed interrupted", e);
Thread.currentThread().interrupt();
} }
canSkipWaitingSet.put(key, true); canSkipWaitingSet.put(key, true);
} }