From 7c047097d99ef935043330cc36e4b3824a4aacdd Mon Sep 17 00:00:00 2001 From: Andrew Werner Date: Tue, 17 Aug 2021 09:25:38 -0400 Subject: [PATCH] roachtest/tests/cdc: effectively disable exponential backoff in jobs Fixes #68963. Release note: None --- pkg/cmd/roachtest/tests/cdc.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/pkg/cmd/roachtest/tests/cdc.go b/pkg/cmd/roachtest/tests/cdc.go index f000c4d00f61..df00e87fd49a 100644 --- a/pkg/cmd/roachtest/tests/cdc.go +++ b/pkg/cmd/roachtest/tests/cdc.go @@ -41,6 +41,7 @@ import ( "github.com/cockroachdb/cockroach/pkg/cmd/roachtest/spec" "github.com/cockroachdb/cockroach/pkg/cmd/roachtest/test" "github.com/cockroachdb/cockroach/pkg/jobs/jobspb" + "github.com/cockroachdb/cockroach/pkg/testutils/sqlutils" "github.com/cockroachdb/cockroach/pkg/util/log" "github.com/cockroachdb/cockroach/pkg/util/protoutil" "github.com/cockroachdb/cockroach/pkg/util/timeutil" @@ -91,9 +92,9 @@ func cdcBasicTest(ctx context.Context, t test.Test, c cluster.Cluster, args cdcT db := c.Conn(ctx, 1) defer stopFeeds(db) - if _, err := db.Exec(`SET CLUSTER SETTING kv.rangefeed.enabled = true`); err != nil { - t.Fatal(err) - } + tdb := sqlutils.MakeSQLRunner(db) + tdb.Exec(t, `SET CLUSTER SETTING kv.rangefeed.enabled = true`) + tdb.Exec(t, `SET CLUSTER SETTING jobs.registry.retry.max_delay = '1s'`) kafka := kafkaManager{ t: t, c: c,