Skip to content

Commit

Permalink
roachtest/tests/cdc: effectively disable exponential backoff in jobs
Browse files Browse the repository at this point in the history
Fixes #68963.

Release note: None
  • Loading branch information
ajwerner committed Aug 17, 2021
1 parent b606f08 commit 7c04709
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions pkg/cmd/roachtest/tests/cdc.go
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down Expand Up @@ -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,
Expand Down

0 comments on commit 7c04709

Please sign in to comment.