@@ -603,7 +603,7 @@ func (rd *replicationDriver) setupC2C(
603
603
destSQL := sqlutils .MakeSQLRunner (destDB )
604
604
605
605
srcClusterSettings (t , srcSQL )
606
- destClusterSettings (t , destSQL , rd .rs .additionalDuration )
606
+ destClusterSettings (t , destSQL , rd .rng , rd . rs .additionalDuration )
607
607
608
608
overrideSrcAndDestTenantTTL (t , srcSQL , destSQL , rd .rs .overrideTenantTTL )
609
609
@@ -1982,7 +1982,9 @@ func srcClusterSettings(t test.Test, db *sqlutils.SQLRunner) {
1982
1982
)
1983
1983
}
1984
1984
1985
- func destClusterSettings (t test.Test , db * sqlutils.SQLRunner , additionalDuration time.Duration ) {
1985
+ func destClusterSettings (
1986
+ t test.Test , db * sqlutils.SQLRunner , rng * rand.Rand , additionalDuration time.Duration ,
1987
+ ) {
1986
1988
db .ExecMultiple (t ,
1987
1989
`SET CLUSTER SETTING kv.rangefeed.enabled = true;` ,
1988
1990
`SET CLUSTER SETTING kv.lease.reject_on_leader_unknown.enabled = true;` ,
@@ -1995,6 +1997,10 @@ func destClusterSettings(t test.Test, db *sqlutils.SQLRunner, additionalDuration
1995
1997
db .Exec (t , fmt .Sprintf (`SET CLUSTER SETTING stream_replication.replan_flow_frequency = '%s'` ,
1996
1998
replanFrequency ))
1997
1999
}
2000
+
2001
+ if rng .Intn (2 ) == 0 {
2002
+ db .Exec (t , `SET CLUSTER SETTING physical_cluster_replication.reader_system_table_id_offset = 100000` )
2003
+ }
1998
2004
}
1999
2005
2000
2006
func overrideSrcAndDestTenantTTL (
0 commit comments