Merge pull request #137810 from cockroachdb/blathers/backport-release…

…-24.2-137774

release-24.2: workload/schemachange: turn on exec logging for all statements

pkg/workload/cli/run.go

@@ -582,8 +582,8 @@ func runRun(gen workload.Generator, urls []string, dbName string) error {
 				}
 				continue
 			}
-			// Log the error so we get the stack trace.
-			log.Errorf(ctx, "%v", err)
+			// Log the error with %+v so we get the stack trace.
+			log.Errorf(ctx, "workload run error: %+v", err)
 			return err
 
 		case <-ticker.C:

pkg/workload/schemachange/operation_generator.go

@@ -3001,6 +3001,10 @@ func (es *ErrorState) Unwrap() error {
 	return es.cause
 }
 
+func (es *ErrorState) Cause() error {
+	return es.cause
+}
+
 func (es *ErrorState) Error() string {
 	return es.cause.Error()
 }

pkg/workload/schemachange/schemachange.go

@@ -338,8 +338,16 @@ func (s *schemaChange) Ops(
 // setClusterSettings configures any settings required for the workload ahead
 // of starting workers.
 func (s *schemaChange) setClusterSettings(ctx context.Context, pool *workload.MultiConnPool) error {
-	_, err := pool.Get().Exec(ctx, `SET CLUSTER SETTING sql.defaults.super_regions.enabled = 'on'`)
-	return errors.WithStack(err)
+	for _, stmt := range []string{
+		`SET CLUSTER SETTING sql.defaults.super_regions.enabled = 'on'`,
+		`SET CLUSTER SETTING sql.log.all_statements.enabled = 'on'`,
+	} {
+		_, err := pool.Get().Exec(ctx, stmt)
+		if err != nil {
+			return errors.WithStack(err)
+		}
+	}
+	return nil
 }
 
 // initSeqName returns the smallest available sequence number to be