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

…ks a connection to ZooKeeper (apache#6147) Co-authored-by: rodenli <[email protected]> Signed-off-by: Duo Zhang <[email protected]>
NihalJain · Sep 4, 2024 · 73651dc · 73651dc
1 parent 63b26b1
commit 73651dc
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
@@ -49,6 +49,9 @@ protected RecoveredReplicationSourceShipper createNewShipper(String walGroupId,
       () -> {
         if (workerThreads.isEmpty()) {
           this.getSourceMetrics().clear();
+          if (this.getReplicationEndpoint() != null) {
+            this.getReplicationEndpoint().stop();
+          }
           manager.finishRecoveredSource(this);
         }
       });