diff --git a/pkg/cmd/roachtest/tests/cdc.go b/pkg/cmd/roachtest/tests/cdc.go index f22129d447e8..020974e870f0 100644 --- a/pkg/cmd/roachtest/tests/cdc.go +++ b/pkg/cmd/roachtest/tests/cdc.go @@ -1905,7 +1905,7 @@ func registerCDC(r registry.Registry) { }) ct.runFeedLatencyVerifier(feed, latencyTargets{ initialScanLatency: 10 * time.Minute, - steadyLatency: time.Minute, + steadyLatency: 3 * time.Minute, }) ct.waitForWorkload() }, diff --git a/pkg/cmd/roachtest/tests/latency_verifier.go b/pkg/cmd/roachtest/tests/latency_verifier.go index b0ebaee774f1..ae7fa6d429a1 100644 --- a/pkg/cmd/roachtest/tests/latency_verifier.go +++ b/pkg/cmd/roachtest/tests/latency_verifier.go @@ -114,7 +114,7 @@ func (lv *latencyVerifier) noteHighwater(highwaterTime time.Time) { return } - if lv.targetSteadyLatency == 0 || latency < lv.targetSteadyLatency/2 { + if lv.targetSteadyLatency == 0 || latency < lv.targetSteadyLatency { lv.latencyBecameSteady = true } if !lv.latencyBecameSteady {