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

close #39955
pingcap · Dec 20, 2022 · 2ed9959 · 2ed9959
1 parent b85be5f
commit 2ed9959
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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")