diff --git a/ttl/ttlworker/job_manager.go b/ttl/ttlworker/job_manager.go index 814d8dbf6df87..43d3f7fbfca88 100644 --- a/ttl/ttlworker/job_manager.go +++ b/ttl/ttlworker/job_manager.go @@ -89,6 +89,7 @@ func NewJobManager(id string, sessPool sessionPool, store kv.Storage) (manager * manager.store = store manager.sessPool = sessPool manager.delCh = make(chan *ttlDeleteTask) + manager.notifyStateCh = make(chan interface{}, 1) manager.init(manager.jobLoop) manager.ctx = logutil.WithKeyValue(manager.ctx, "ttl-worker", "manager")