HBASE-28669 After one RegionServer restarts, another RegionServer lea…

…ks a connection to ZooKeeper (#6207) Signed-off-by: Duo Zhang <[email protected]> Co-authored-by: rodenli <[email protected]> (cherry picked from commit 4da8880)
apache · Sep 6, 2024 · 1aa73e3 · 1aa73e3
1 parent dbf8acf
commit 1aa73e3
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...ain/java/org/apache/hadoop/hbase/replication/regionserver/RecoveredReplicationSource.java b/...ain/java/org/apache/hadoop/hbase/replication/regionserver/RecoveredReplicationSource.java
@@ -149,6 +149,9 @@ void tryFinish() {
       boolean allTasksDone = workerThreads.values().stream().allMatch(w -> w.isFinished());
       if (allTasksDone) {
         this.getSourceMetrics().clear();
+        if (this.getReplicationEndpoint() != null) {
+          this.getReplicationEndpoint().stop();
+        }
         manager.removeRecoveredSource(this);
         LOG.info("Finished recovering queue {} with the following stats: {}", queueId, getStats());
       }