diff --git a/go/test/endtoend/vtorc/primaryfailure/primary_failure_test.go b/go/test/endtoend/vtorc/primaryfailure/primary_failure_test.go index e5588c2321d..190e5e66501 100644 --- a/go/test/endtoend/vtorc/primaryfailure/primary_failure_test.go +++ b/go/test/endtoend/vtorc/primaryfailure/primary_failure_test.go @@ -35,16 +35,22 @@ func TestDownPrimary(t *testing.T) { defer utils.PrintVTOrcLogsOnFailure(t, clusterInfo.ClusterInstance) defer cluster.PanicHandler(t) <<<<<<< HEAD +<<<<<<< HEAD <<<<<<< HEAD utils.SetupVttabletsAndVTOrcs(t, clusterInfo, 2, 1, nil, cluster.VTOrcConfiguration{ ======= ======= +>>>>>>> 888df9228e (Fix flakiness in VTOrc tests (#13489)) +======= >>>>>>> 888df9228e (Fix flakiness in VTOrc tests (#13489)) // We specify the --wait-replicas-timeout to a small value because we spawn a cross-cell replica later in the test. // If that replica is more advanced than the same-cell-replica, then we try to promote the cross-cell replica as an intermediate source. // If we don't specify a small value of --wait-replicas-timeout, then we would end up waiting for 30 seconds for the dead-primary to respond, failing this test. utils.SetupVttabletsAndVTOrcs(t, clusterInfo, 2, 1, []string{"--remote_operation_timeout=10s", "--wait-replicas-timeout=5s"}, cluster.VTOrcConfiguration{ <<<<<<< HEAD +<<<<<<< HEAD +>>>>>>> 888df9228e (Fix flakiness in VTOrc tests (#13489)) +======= >>>>>>> 888df9228e (Fix flakiness in VTOrc tests (#13489)) ======= >>>>>>> 888df9228e (Fix flakiness in VTOrc tests (#13489)) diff --git a/go/test/endtoend/vtorc/utils/utils.go b/go/test/endtoend/vtorc/utils/utils.go index c2cdf30427b..bc817f58094 100644 --- a/go/test/endtoend/vtorc/utils/utils.go +++ b/go/test/endtoend/vtorc/utils/utils.go @@ -1001,6 +1001,9 @@ func PrintVTOrcLogsOnFailure(t *testing.T, clusterInstance *cluster.LocalProcess } } <<<<<<< HEAD +<<<<<<< HEAD +>>>>>>> 888df9228e (Fix flakiness in VTOrc tests (#13489)) +======= >>>>>>> 888df9228e (Fix flakiness in VTOrc tests (#13489)) ======= >>>>>>> 888df9228e (Fix flakiness in VTOrc tests (#13489)) diff --git a/go/vt/vtorc/inst/instance_dao.go b/go/vt/vtorc/inst/instance_dao.go index 2bc9105077a..487cb3b1143 100644 --- a/go/vt/vtorc/inst/instance_dao.go +++ b/go/vt/vtorc/inst/instance_dao.go @@ -105,6 +105,9 @@ func initializeInstanceDao() { forgetAliases = cache.New(time.Duration(config.Config.InstancePollSeconds*3)*time.Second, time.Second) cacheInitializationCompleted.Store(true) <<<<<<< HEAD +<<<<<<< HEAD +>>>>>>> 888df9228e (Fix flakiness in VTOrc tests (#13489)) +======= >>>>>>> 888df9228e (Fix flakiness in VTOrc tests (#13489)) ======= >>>>>>> 888df9228e (Fix flakiness in VTOrc tests (#13489)) diff --git a/go/vt/vtorc/inst/instance_dao_test.go b/go/vt/vtorc/inst/instance_dao_test.go index 91578cbe2fb..453cfb11033 100644 --- a/go/vt/vtorc/inst/instance_dao_test.go +++ b/go/vt/vtorc/inst/instance_dao_test.go @@ -646,6 +646,9 @@ func waitForCacheInitialization() { } } <<<<<<< HEAD +<<<<<<< HEAD +>>>>>>> 888df9228e (Fix flakiness in VTOrc tests (#13489)) +======= >>>>>>> 888df9228e (Fix flakiness in VTOrc tests (#13489)) ======= >>>>>>> 888df9228e (Fix flakiness in VTOrc tests (#13489))