diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/RecoveredReplicationSource.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/RecoveredReplicationSource.java
index e47df36e3aa2..68c41316d17d 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/RecoveredReplicationSource.java
+++ b/hbase-server/src/main/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);
         }
       });