initialize notifyStateCh in ttl job manager

Signed-off-by: YangKeao <[email protected]>
pingcap · Dec 15, 2022 · 9a36920 · 9a36920
1 parent c26a6b5
commit 9a36920
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/ttl/ttlworker/job_manager.go b/ttl/ttlworker/job_manager.go
@@ -90,6 +90,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")