diff --git a/planner/core/logical_plan_builder.go b/planner/core/logical_plan_builder.go index bbd6da8372101..e4529bb407cc9 100644 --- a/planner/core/logical_plan_builder.go +++ b/planner/core/logical_plan_builder.go @@ -4204,12 +4204,14 @@ func (b *PlanBuilder) buildDataSource(ctx context.Context, tn *ast.TableName, as result = us } else { if !b.inUpdateStmt && !b.inDeleteStmt && !sessionVars.StmtCtx.InExplainStmt { + startTS := txn.StartTS() + store := b.ctx.GetStore() go func() { defer func() { if r := recover(); r != nil { } }() - err := cachedTable.UpdateLockForRead(b.ctx.GetStore(), txn.StartTS()) + err := cachedTable.UpdateLockForRead(store, startTS) if err != nil { log.Warn("Update Lock Info Error") }