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

…) (#9924) close #9915
pingcap · Oct 18, 2023 · a9cc735 · a9cc735
1 parent 7c9bc3f
commit a9cc735
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()