HBASE-26816 Fix CME in ReplicationSourceManager (#4187)

Signed-off-by: Duo Zhang <zhangduo@apache.org>
apache · Mar 11, 2022 · dbf5681 · dbf5681
1 parent addace2
commit dbf5681
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/.../main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.java b/.../main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.java
@@ -906,8 +906,10 @@ public void join() {
     for (ReplicationSourceInterface source : this.sources.values()) {
       source.terminate("Region server is closing");
     }
-    for (ReplicationSourceInterface source : this.oldsources) {
-      source.terminate("Region server is closing");
+    synchronized (oldsources) {
+      for (ReplicationSourceInterface source : this.oldsources) {
+        source.terminate("Region server is closing");
+      }
     }
   }