diff --git a/pkg/upstream/manager.go b/pkg/upstream/manager.go index 4dcc89d4302..6cd90ef92e7 100644 --- 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()