Skip to content

Commit 66460bf

Browse files
craig[bot]erikgrinaker
andcommitted
Merge #118469
118469: rangefeed: use `MakeTestingClusterSettings()` r=erikgrinaker a=erikgrinaker Otherwise, this can cause spurious failures like: ``` cannot initialize version to 23.1 because already set to: 23.2 ``` Epic: none Release note: None Co-authored-by: Erik Grinaker <[email protected]>
2 parents a36097b + 76256c5 commit 66460bf

File tree

1 file changed

+12
-12
lines changed

1 file changed

+12
-12
lines changed

pkg/kv/kvclient/rangefeed/rangefeed_external_test.go

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ func TestRangeFeedIntegration(t *testing.T) {
6767
defer log.Scope(t).Close(t)
6868

6969
ctx := context.Background()
70-
settings := cluster.MakeClusterSettings()
70+
settings := cluster.MakeTestingClusterSettings()
7171
srv, _, db := serverutils.StartServer(t, base.TestServerArgs{
7272
Settings: settings,
7373
})
@@ -163,7 +163,7 @@ func TestWithOnFrontierAdvance(t *testing.T) {
163163
defer log.Scope(t).Close(t)
164164

165165
ctx := context.Background()
166-
settings := cluster.MakeClusterSettings()
166+
settings := cluster.MakeTestingClusterSettings()
167167
tc := testcluster.StartTestCluster(t, 1, base.TestClusterArgs{
168168
ReplicationMode: base.ReplicationManual,
169169
ServerArgs: base.TestServerArgs{Settings: settings},
@@ -288,7 +288,7 @@ func TestWithOnCheckpoint(t *testing.T) {
288288
defer log.Scope(t).Close(t)
289289

290290
ctx := context.Background()
291-
settings := cluster.MakeClusterSettings()
291+
settings := cluster.MakeTestingClusterSettings()
292292
srv, _, db := serverutils.StartServer(t, base.TestServerArgs{
293293
Settings: settings,
294294
})
@@ -388,7 +388,7 @@ func TestRangefeedValueTimestamps(t *testing.T) {
388388
defer log.Scope(t).Close(t)
389389

390390
ctx := context.Background()
391-
settings := cluster.MakeClusterSettings()
391+
settings := cluster.MakeTestingClusterSettings()
392392
srv, _, db := serverutils.StartServer(t, base.TestServerArgs{
393393
Settings: settings,
394394
})
@@ -502,7 +502,7 @@ func TestWithOnSSTable(t *testing.T) {
502502
defer log.Scope(t).Close(t)
503503

504504
ctx := context.Background()
505-
settings := cluster.MakeClusterSettings()
505+
settings := cluster.MakeTestingClusterSettings()
506506
srv, _, db := serverutils.StartServer(t, base.TestServerArgs{
507507
Settings: settings,
508508
DefaultTestTenant: base.TestIsForStuffThatShouldWorkWithSecondaryTenantsButDoesntYet(109473),
@@ -601,7 +601,7 @@ func TestWithOnSSTableCatchesUpIfNotSet(t *testing.T) {
601601
ctx, cancel := context.WithCancel(context.Background())
602602
defer cancel()
603603

604-
settings := cluster.MakeClusterSettings()
604+
settings := cluster.MakeTestingClusterSettings()
605605
tc := testcluster.StartTestCluster(t, 1, base.TestClusterArgs{
606606
ServerArgs: base.TestServerArgs{
607607
DefaultTestTenant: base.TestIsForStuffThatShouldWorkWithSecondaryTenantsButDoesntYet(109473),
@@ -707,7 +707,7 @@ func TestWithOnDeleteRange(t *testing.T) {
707707
defer log.Scope(t).Close(t)
708708

709709
ctx := context.Background()
710-
settings := cluster.MakeClusterSettings()
710+
settings := cluster.MakeTestingClusterSettings()
711711
tc := testcluster.StartTestCluster(t, 1, base.TestClusterArgs{
712712
ServerArgs: base.TestServerArgs{
713713
Settings: settings,
@@ -888,7 +888,7 @@ func TestUnrecoverableErrors(t *testing.T) {
888888
defer log.Scope(t).Close(t)
889889

890890
ctx := context.Background()
891-
settings := cluster.MakeClusterSettings()
891+
settings := cluster.MakeTestingClusterSettings()
892892
srv, sqlDB, kvDB := serverutils.StartServer(t, base.TestServerArgs{
893893
DefaultTestTenant: base.TestIsForStuffThatShouldWorkWithSecondaryTenantsButDoesntYet(109472),
894894
Knobs: base.TestingKnobs{
@@ -984,7 +984,7 @@ func TestMVCCHistoryMutationError(t *testing.T) {
984984
ctx, cancel := context.WithCancel(context.Background())
985985
defer cancel()
986986

987-
settings := cluster.MakeClusterSettings()
987+
settings := cluster.MakeTestingClusterSettings()
988988
srv, _, db := serverutils.StartServer(t, base.TestServerArgs{
989989
Settings: settings,
990990
})
@@ -1066,7 +1066,7 @@ func TestRangefeedWithLabelsOption(t *testing.T) {
10661066
defer log.Scope(t).Close(t)
10671067

10681068
ctx := context.Background()
1069-
settings := cluster.MakeClusterSettings()
1069+
settings := cluster.MakeTestingClusterSettings()
10701070
srv, _, db := serverutils.StartServer(t, base.TestServerArgs{
10711071
Settings: settings,
10721072
})
@@ -1179,7 +1179,7 @@ func TestRangeFeedStartTimeExclusive(t *testing.T) {
11791179
defer log.Scope(t).Close(t)
11801180

11811181
ctx := context.Background()
1182-
settings := cluster.MakeClusterSettings()
1182+
settings := cluster.MakeTestingClusterSettings()
11831183
srv, _, db := serverutils.StartServer(t, base.TestServerArgs{
11841184
Settings: settings,
11851185
})
@@ -1312,7 +1312,7 @@ func TestRangeFeedIntentResolutionRace(t *testing.T) {
13121312

13131313
// Speed up the test by reducing various closed/resolved timestamp intervals.
13141314
const interval = 100 * time.Millisecond
1315-
st := cluster.MakeClusterSettings()
1315+
st := cluster.MakeTestingClusterSettings()
13161316
kvserver.RangeFeedRefreshInterval.Override(ctx, &st.SV, interval)
13171317
closedts.SideTransportCloseInterval.Override(ctx, &st.SV, interval)
13181318
closedts.TargetDuration.Override(ctx, &st.SV, interval)

0 commit comments

Comments
 (0)