diff --git a/pkg/config/etcd_source.go b/pkg/config/etcd_source.go index 29f49278d76b..25301bfd7fb1 100644 --- a/pkg/config/etcd_source.go +++ b/pkg/config/etcd_source.go @@ -180,10 +180,10 @@ func (es *EtcdSource) update(configs map[string]string) error { return err } es.currentConfigs = configs + es.Unlock() if es.manager != nil { es.manager.EvictCacheValueByFormat(lo.Map(events, func(event *Event, _ int) string { return event.Key })...) } - es.Unlock() es.configRefresher.fireEvents(events...) return nil diff --git a/pkg/config/file_source.go b/pkg/config/file_source.go index 9a1ab3f863e0..4fbb341652f7 100644 --- a/pkg/config/file_source.go +++ b/pkg/config/file_source.go @@ -181,10 +181,10 @@ func (fs *FileSource) update(configs map[string]string) error { return err } fs.configs = configs + fs.Unlock() if fs.manager != nil { fs.manager.EvictCacheValueByFormat(lo.Map(events, func(event *Event, _ int) string { return event.Key })...) } - fs.Unlock() fs.configRefresher.fireEvents(events...) return nil