From 4643320e7b0e4306596402e7cedb10d3cd5a3199 Mon Sep 17 00:00:00 2001 From: "vitess-bot[bot]" <108069721+vitess-bot[bot]@users.noreply.github.com> Date: Tue, 18 Jul 2023 17:29:13 +0530 Subject: [PATCH] Cherry-pick 888df9228e94b2fad4e57af0f55ce68f8236bf25 with conflicts --- .../endtoend/vtorc/primaryfailure/primary_failure_test.go | 6 ++++++ go/test/endtoend/vtorc/utils/utils.go | 3 +++ go/vt/vtorc/inst/instance_dao.go | 3 +++ go/vt/vtorc/inst/instance_dao_test.go | 3 +++ 4 files changed, 15 insertions(+) diff --git a/go/test/endtoend/vtorc/primaryfailure/primary_failure_test.go b/go/test/endtoend/vtorc/primaryfailure/primary_failure_test.go index 190e5e66501..59c2545836d 100644 --- a/go/test/endtoend/vtorc/primaryfailure/primary_failure_test.go +++ b/go/test/endtoend/vtorc/primaryfailure/primary_failure_test.go @@ -36,12 +36,15 @@ func TestDownPrimary(t *testing.T) { defer cluster.PanicHandler(t) <<<<<<< HEAD <<<<<<< 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)) +======= >>>>>>> 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. @@ -49,6 +52,9 @@ func TestDownPrimary(t *testing.T) { utils.SetupVttabletsAndVTOrcs(t, clusterInfo, 2, 1, []string{"--remote_operation_timeout=10s", "--wait-replicas-timeout=5s"}, cluster.VTOrcConfiguration{ <<<<<<< HEAD <<<<<<< 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 bc817f58094..fc67e8c3013 100644 --- a/go/test/endtoend/vtorc/utils/utils.go +++ b/go/test/endtoend/vtorc/utils/utils.go @@ -1002,6 +1002,9 @@ func PrintVTOrcLogsOnFailure(t *testing.T, clusterInstance *cluster.LocalProcess } <<<<<<< HEAD <<<<<<< 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 487cb3b1143..064e55957b0 100644 --- a/go/vt/vtorc/inst/instance_dao.go +++ b/go/vt/vtorc/inst/instance_dao.go @@ -106,6 +106,9 @@ func initializeInstanceDao() { cacheInitializationCompleted.Store(true) <<<<<<< HEAD <<<<<<< 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 453cfb11033..6dfb30c4de6 100644 --- a/go/vt/vtorc/inst/instance_dao_test.go +++ b/go/vt/vtorc/inst/instance_dao_test.go @@ -647,6 +647,9 @@ func waitForCacheInitialization() { } <<<<<<< HEAD <<<<<<< HEAD +<<<<<<< HEAD +>>>>>>> 888df9228e (Fix flakiness in VTOrc tests (#13489)) +======= >>>>>>> 888df9228e (Fix flakiness in VTOrc tests (#13489)) ======= >>>>>>> 888df9228e (Fix flakiness in VTOrc tests (#13489))