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

HBASE-18111 Replication stuck when cluster connection is closed 

Signed-off-by: Andrew Purtell <apurtell@apache.org>
This commit is contained in:
Guanghao Zhang 2017-05-25 09:51:40 +08:00 committed by Andrew Purtell
parent e1f3c89b3b
commit 549171465d
1 changed files with 15 additions and 0 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/HBaseInterClusterReplicationEndpoint.java
View File

@ -225,6 +225,18 @@ public class HBaseInterClusterReplicationEndpoint extends HBaseReplicationEndpoi
return entryLists; return entryLists;
} }
private void reconnectToPeerCluster() {
ClusterConnection connection = null;
try {
connection = (ClusterConnection) ConnectionFactory.createConnection(this.conf);
} catch (IOException ioe) {
LOG.warn("Failed to create connection for peer cluster", ioe);
}
if (connection != null) {
this.conn = connection;
}
}
/** /**
* Do the shipping logic * Do the shipping logic
*/ */
@ -256,6 +268,9 @@ public class HBaseInterClusterReplicationEndpoint extends HBaseReplicationEndpoi
} }
continue; continue;
} }
if (this.conn == null || this.conn.isClosed()) {
reconnectToPeerCluster();
}
try { try {
int futures = 0; int futures = 0;
for (int i=0; i<batches.size(); i++) { for (int i=0; i<batches.size(); i++) {