diff --git a/internal/mvcc/watchable_store.go b/internal/mvcc/watchable_store.go index 34d4d32656bc..054be1034cb4 100644 --- a/internal/mvcc/watchable_store.go +++ b/internal/mvcc/watchable_store.go @@ -192,7 +192,7 @@ func (s *watchableStore) Restore(b backend.Backend) error { } for wa := range s.synced.watchers { - s.unsynced.watchers.add(wa) + s.unsynced.add(wa) } s.synced = newWatcherGroup() return nil