HBASE-27249 Remove invalid peer RegionServer crash

Author: SiCheng-Zheng

hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java

@@ -540,7 +540,7 @@ private void initialize() {
 
     if (!this.isSourceActive()) {
       setSourceStartupStatus(false);
-      if (Thread.currentThread().isInterrupted()) {
+      if (Thread.currentThread().isInterrupted() || !this.sourceRunning) {
         // If source is not running and thread is interrupted this means someone has tried to
         // remove this peer.
         return;
@@ -570,7 +570,7 @@ private void initialize() {
 
     if (!this.isSourceActive()) {
       setSourceStartupStatus(false);
-      if (Thread.currentThread().isInterrupted()) {
+      if (Thread.currentThread().isInterrupted() || !this.sourceRunning) {
         // If source is not running and thread is interrupted this means someone has tried to
         // remove this peer.
         return;