From dbeab313e022cecc36f00c01a48d749567b70b3f Mon Sep 17 00:00:00 2001 From: Yu Xia Date: Wed, 1 Feb 2023 16:24:10 -0800 Subject: [PATCH] clean replication task processor after disconnect (#3882) --- service/history/replication/task_processor_manager.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/service/history/replication/task_processor_manager.go b/service/history/replication/task_processor_manager.go index 22a1b3d5214..757a4728119 100644 --- a/service/history/replication/task_processor_manager.go +++ b/service/history/replication/task_processor_manager.go @@ -182,8 +182,8 @@ func (r *taskProcessorManagerImpl) handleClusterMetadataUpdate( } for _, processor := range r.taskProcessors[clusterName] { processor.Stop() - delete(r.taskProcessors, clusterName) } + delete(r.taskProcessors, clusterName) } // Case 2 and Case 3