changefeed(ticdc): check changefeed info is nil to prevent panic (#9917)

close #9915
pingcap · Oct 18, 2023 · 0a70e3a · 0a70e3a
1 parent c988064
commit 0a70e3a
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pkg/upstream/manager.go b/pkg/upstream/manager.go
@@ -196,7 +196,9 @@ func (m *Manager) Tick(ctx context.Context,
 
 	activeUpstreams := make(map[uint64]struct{})
 	for _, cf := range globalState.Changefeeds {
-		activeUpstreams[cf.Info.UpstreamID] = struct{}{}
+		if cf != nil && cf.Info != nil {
+			activeUpstreams[cf.Info.UpstreamID] = struct{}{}
+		}
 	}
 	m.mu.Lock()
 	defer m.mu.Unlock()