@@ -575,7 +575,7 @@ func (rd *replicationDriver) setupC2C(
575
575
destSQL := sqlutils .MakeSQLRunner (destDB )
576
576
577
577
srcClusterSettings (t , srcSQL )
578
- destClusterSettings (t , destSQL , rd .rs .additionalDuration )
578
+ destClusterSettings (t , destSQL , rd .rng , rd . rs .additionalDuration )
579
579
580
580
overrideSrcAndDestTenantTTL (t , srcSQL , destSQL , rd .rs .overrideTenantTTL )
581
581
@@ -1869,7 +1869,9 @@ func srcClusterSettings(t test.Test, db *sqlutils.SQLRunner) {
1869
1869
)
1870
1870
}
1871
1871
1872
- func destClusterSettings (t test.Test , db * sqlutils.SQLRunner , additionalDuration time.Duration ) {
1872
+ func destClusterSettings (
1873
+ t test.Test , db * sqlutils.SQLRunner , rng * rand.Rand , additionalDuration time.Duration ,
1874
+ ) {
1873
1875
db .ExecMultiple (t ,
1874
1876
`SET CLUSTER SETTING kv.rangefeed.enabled = true;` ,
1875
1877
`SET CLUSTER SETTING kv.lease.reject_on_leader_unknown.enabled = true;` ,
@@ -1881,6 +1883,10 @@ func destClusterSettings(t test.Test, db *sqlutils.SQLRunner, additionalDuration
1881
1883
db .Exec (t , fmt .Sprintf (`SET CLUSTER SETTING stream_replication.replan_flow_frequency = '%s'` ,
1882
1884
replanFrequency ))
1883
1885
}
1886
+
1887
+ if rng .Intn (2 ) == 0 {
1888
+ db .Exec (t , `SET CLUSTER SETTING physical_cluster_replication.reader_system_table_id_offset = 100000` )
1889
+ }
1884
1890
}
1885
1891
1886
1892
func overrideSrcAndDestTenantTTL (
0 commit comments