Skip to content

Commit

Permalink
fix TestVSchemaChangesUnderLoad
Browse files Browse the repository at this point in the history
Signed-off-by: Vilius Okockis <[email protected]>
  • Loading branch information
DeathBorn committed Apr 11, 2024
1 parent 4c63e9c commit 7fe7365
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions go/test/endtoend/vreplication/vschema_load_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -135,7 +135,7 @@ func TestVSchemaChangesUnderLoad(t *testing.T) {
defer timer.Stop()
log.Infof("Started ApplyVSchema")
for {
if err := vc.VtctlClient.ExecuteCommand("ApplyVSchema", "--", "--vschema={}", "product"); err != nil {
if err := vc.VtctlClient.ExecuteCommand("ApplyVSchema", "-vschema", "{}", "product"); err != nil {
log.Errorf("ApplyVSchema command failed with %+v\n", err)
return
}
Expand All @@ -155,8 +155,8 @@ func TestVSchemaChangesUnderLoad(t *testing.T) {
}()

<-ch // wait for enough ApplyVSchema calls before doing a PRS
if err := vc.VtctlClient.ExecuteCommand("PlannedReparentShard", "--", "--keyspace_shard", "product/0",
"--new_master", "zone1-101", "--wait_replicas_timeout", defaultTimeout.String()); err != nil {
if err := vc.VtctlClient.ExecuteCommand("PlannedReparentShard", "-keyspace_shard", "product/0",
"-new_master", "zone1-101", "-wait_replicas_timeout", defaultTimeout.String()); err != nil {
require.NoError(t, err, "PlannedReparentShard command failed")
}
}

0 comments on commit 7fe7365

Please sign in to comment.