From 122517013c14e334a85617f61de67df998a96bb0 Mon Sep 17 00:00:00 2001
From: CharlesCheung <61726649+CharlesCheung96@users.noreply.github.com>
Date: Wed, 12 Jul 2023 22:18:43 +0800
Subject: [PATCH] sink, processor(ticdc): do not close table sink when closing
 sinkManager (#9381)

ref pingcap/tiflow#9226, ref pingcap/tiflow#9370
---
 cdc/processor/sinkmanager/manager.go | 8 --------
 1 file changed, 8 deletions(-)

diff --git a/cdc/processor/sinkmanager/manager.go b/cdc/processor/sinkmanager/manager.go
index 2d731bf1aa7..2c53c463de8 100644
--- a/cdc/processor/sinkmanager/manager.go
+++ b/cdc/processor/sinkmanager/manager.go
@@ -1022,14 +1022,6 @@ func (m *SinkManager) Close() {
 
 	start := time.Now()
 	m.waitSubroutines()
-	m.tableSinks.Range(func(_ tablepb.Span, value interface{}) bool {
-		sink := value.(*tableSinkWrapper)
-		sink.close()
-		if m.eventCache != nil {
-			m.eventCache.removeTable(sink.span)
-		}
-		return true
-	})
 	m.clearSinkFactory()
 
 	log.Info("Closed sink manager",