diff --git a/go/test/endtoend/backup/vtctlbackup/backup_utils.go b/go/test/endtoend/backup/vtctlbackup/backup_utils.go index c20072c4eee..c794f210d38 100644 --- a/go/test/endtoend/backup/vtctlbackup/backup_utils.go +++ b/go/test/endtoend/backup/vtctlbackup/backup_utils.go @@ -132,7 +132,7 @@ func LaunchCluster(setupType int, streamMode string, stripes int, cDetails *Comp return 1, err } newInitDBFile = path.Join(localCluster.TmpDirectory, "init_db_with_passwords.sql") - err = os.WriteFile(newInitDBFile, []byte(sql), 0666) + err = os.WriteFile(newInitDBFile, []byte(sql), 0o666) if err != nil { return 1, err } @@ -544,10 +544,10 @@ func primaryBackup(t *testing.T) { _, err = primary.VttabletProcess.QueryTablet("DROP TABLE vt_insert_test", keyspaceName, true) require.NoError(t, err) + + restartPrimaryAndReplica(t) } -// Test a primary and replica from the same backup. -// // Check that a replica and primary both restored from the same backup // can replicate successfully. func primaryReplicaSameBackup(t *testing.T) { diff --git a/go/vt/vttablet/grpctmclient/client.go b/go/vt/vttablet/grpctmclient/client.go index 24e44a57214..289930d3c5c 100644 --- a/go/vt/vttablet/grpctmclient/client.go +++ b/go/vt/vttablet/grpctmclient/client.go @@ -580,7 +580,7 @@ func (client *Client) ExecuteFetchAsDba(ctx context.Context, tablet *topodatapb. DbName: topoproto.TabletDbName(tablet), MaxRows: req.MaxRows, DisableBinlogs: req.DisableBinlogs, - ReloadSchema: req.DisableBinlogs, + ReloadSchema: req.ReloadSchema, DisableForeignKeyChecks: req.DisableForeignKeyChecks, }) if err != nil { @@ -616,7 +616,7 @@ func (client *Client) ExecuteMultiFetchAsDba(ctx context.Context, tablet *topoda DbName: topoproto.TabletDbName(tablet), MaxRows: req.MaxRows, DisableBinlogs: req.DisableBinlogs, - ReloadSchema: req.DisableBinlogs, + ReloadSchema: req.ReloadSchema, DisableForeignKeyChecks: req.DisableForeignKeyChecks, }) if err != nil {