From 5ce277b8f2d747a665aa8872b58bffd9c72acf1d Mon Sep 17 00:00:00 2001 From: YangKeao Date: Wed, 14 Dec 2022 22:40:52 -0500 Subject: [PATCH] ttl: initialize notifyStateCh in ttl job manager (#39956) close pingcap/tidb#39955 --- ttl/ttlworker/job_manager.go | 1 + 1 file changed, 1 insertion(+) diff --git a/ttl/ttlworker/job_manager.go b/ttl/ttlworker/job_manager.go index a141cfc046fb3..f8627178023a8 100644 --- 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")