fix ut

pingcap · Nov 30, 2021 · 2227e75 · 2227e75
1 parent 6cd2eaa
commit 2227e75
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/cdc/sink/manager.go b/cdc/sink/manager.go
@@ -88,7 +88,10 @@ func (m *Manager) CreateTableSink(tableID model.TableID, checkpointTs model.Ts,
 // Close closes the Sink manager and backend Sink, this method can be reentrantly called
 func (m *Manager) Close(ctx context.Context) error {
 	tableSinkTotalRowsCountCounter.DeleteLabelValues(m.captureAddr, m.changefeedID)
-	return m.backendSink.Close(ctx)
+	if m.backendSink != nil {
+		return m.backendSink.Close(ctx)
+	}
+	return nil
 }
 
 func (m *Manager) getMinEmittedTs(tableID model.TableID) model.Ts {