sink, processor(ticdc): do not close table sink when closing sinkMana…

…ger (#9381) ref #9226, ref #9370
pingcap · Jul 12, 2023 · 1225170 · 1225170
1 parent 5eb63ca
commit 1225170
Showing 1 changed file with 0 additions and 8 deletions.
diff --git 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",