ttl: initialize notifyStateCh in ttl job manager (pingcap#39956)

close pingcap#39955
ti-chi-bot · Dec 20, 2022 · 5ce277b · 5ce277b
1 parent 06290cd
commit 5ce277b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/ttl/ttlworker/job_manager.go b/ttl/ttlworker/job_manager.go
@@ -88,6 +88,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")