upd

pingcap · Nov 30, 2022 · 0c8c0e9 · 0c8c0e9
1 parent fec40dd
commit 0c8c0e9
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/executor/adapter.go b/executor/adapter.go
@@ -479,7 +479,9 @@ func (a *ExecStmt) Exec(ctx context.Context) (_ sqlexec.RecordSet, err error) {
 		if err2 == nil {
 			concurrency, err3 := strconv.ParseInt(sVal, 10, 64)
 			terror.Log(err3)
-			sctx.GetSessionVars().SetDistSQLScanConcurrency(int(concurrency))
+			if err3 == nil {
+				sctx.GetSessionVars().SetDistSQLScanConcurrency(int(concurrency))
+			}
 		}
 		sctx.GetSessionVars().SetIndexSerialScanConcurrency(1)
 		terror.Log(sctx.GetSessionVars().SetSystemVar(variable.TxnIsolation, ast.ReadCommitted))