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

HBASE-25012 HBASE-24359 causes replication missed log of some RemoteException (#2383) 

Signed-off-by: Wellington Chevreuil <wchevreuil@apache.org>
Signed-off-by: Guanghao Zhang <zghao@apache.org>
This commit is contained in:
XinSun 2020-09-16 18:00:35 +08:00 committed by GitHub
parent 5a610cb055
commit d15074981f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HBaseInterClusterReplicationEndpoint.java
View File

@ -559,10 +559,14 @@ public class HBaseInterClusterReplicationEndpoint extends HBaseReplicationEndpoi
} else if (dropOnDeletedColumnFamilies && isNoSuchColumnFamilyException(ioe)) { } else if (dropOnDeletedColumnFamilies && isNoSuchColumnFamilyException(ioe)) {
batches = filterNotExistColumnFamilyEdits(batches); batches = filterNotExistColumnFamilyEdits(batches);
if (batches.isEmpty()) { if (batches.isEmpty()) {
LOG.warn( LOG.warn("After filter not exist column family's edits, 0 edits to replicate, "
"After filter not exist column family's edits, 0 edits to replicate, just return"); + "just return");
return true; return true;
} }
} else {
LOG.warn("{} Peer encountered RemoteException, rechecking all sinks: ", logPeerId(),
ioe);
replicationSinkMgr.chooseSinks();
} }
} else { } else {
if (ioe instanceof SocketTimeoutException) { if (ioe instanceof SocketTimeoutException) {