diff --git a/pkg/executor/adapter.go b/pkg/executor/adapter.go index 0678f3217945a..cd1f3affea5c6 100644 --- a/pkg/executor/adapter.go +++ b/pkg/executor/adapter.go @@ -555,7 +555,12 @@ func (a *ExecStmt) Exec(ctx context.Context) (_ sqlexec.RecordSet, err error) { return nil, err } if len(switchGroupName) > 0 { - stmtCtx.ResourceGroupName = switchGroupName + group, err := rm.ResourceGroupCtl.GetResourceGroup(switchGroupName) + if err != nil || group == nil { + logutil.BgLogger().Debug("invalid switch resource group", zap.String("switch-group-name", switchGroupName), zap.Error(err)) + } else { + stmtCtx.ResourceGroupName = switchGroupName + } } } ctx = a.observeStmtBeginForTopSQL(ctx)