Merge pull request #8836 from utk9/utkarsh/osc_cutover_user

Use vt_dba user for online schema migration cutover phase
vitessio · Sep 22, 2021 · b04726d · b04726d
2 parents 6c677b9 + 08f689f
commit b04726d
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/go/vt/vttablet/onlineddl/executor.go b/go/vt/vttablet/onlineddl/executor.go
@@ -679,7 +679,12 @@ func (e *Executor) cutOverVReplMigration(ctx context.Context, s *VReplStream) er
 				vreplTable, onlineDDL.Table,
 				swapTable, vreplTable,
 			)
-			if _, err = e.execQuery(ctx, parsed.Query); err != nil {
+			conn, err := dbconnpool.NewDBConnection(ctx, e.env.Config().DB.DbaWithDB())
+			if err != nil {
+				return err
+			}
+			defer conn.Close()
+			if _, err = conn.ExecuteFetch(parsed.Query, 0, false); err != nil {
 				return err
 			}
 		}