diff --git a/session/session.go b/session/session.go index ffb343aeb8a00..2d9849eed0dd2 100644 --- a/session/session.go +++ b/session/session.go @@ -2189,7 +2189,16 @@ func (s *session) ExecuteStmt(ctx context.Context, stmtNode ast.StmtNode) (sqlex } }) - stmtLabel := ast.GetStmtLabel(stmtNode) + var stmtLabel string + if execStmt, ok := stmtNode.(*ast.ExecuteStmt); ok { + prepareStmt, err := plannercore.GetPreparedStmt(execStmt, s.sessionVars) + if err == nil && prepareStmt.PreparedAst != nil { + stmtLabel = ast.GetStmtLabel(prepareStmt.PreparedAst.Stmt) + } + } + if stmtLabel == "" { + stmtLabel = ast.GetStmtLabel(stmtNode) + } s.setRequestSource(ctx, stmtLabel, stmtNode) // Backup the original resource group name since sql hint might change it during optimization