Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
D3Hunter committed May 30, 2024
1 parent df8dffd commit 95022b0
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion pkg/ddl/job_table.go
Original file line number Diff line number Diff line change
Expand Up @@ -514,7 +514,7 @@ func (s *jobScheduler) delivery2Worker(wk *worker, pool *workerPool, job *model.
s.runningJobs.remove(job)
asyncNotify(s.ddlJobNotifyCh)
metrics.DDLRunningJobCount.WithLabelValues(pool.tp().String()).Dec()
if wk.ctx.Err() != nil {
if wk.ctx.Err() != nil && ingest.LitBackCtxMgr != nil {
// if ctx cancelled, i.e. owner changed, we need to Unregister the backend
// as litBackendCtx is holding this very 'ctx', and it cannot reuse now.
// TODO make LitBackCtxMgr a local value of the job scheduler, it makes
Expand Down

0 comments on commit 95022b0

Please sign in to comment.