From 51f06589834c8f5688030660818d159510a98266 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 f067522411da7..58c47d05efe4f 100644 --- 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")