Set the new schema for the faulty measurements table

LDiazN · LDiazN · commit 99ccce25040b · 2026-02-18T12:52:26.000+01:00
diff --git a/scripts/cluster-migration/schema.sql b/scripts/cluster-migration/schema.sql
@@ -220,6 +220,7 @@ CREATE TABLE IF NOT EXISTS faulty_measurements ON CLUSTER oonidata_cluster
 (
     `ts` DateTime64(3, 'UTC'),
     `type` String,
+    `measurement_uid` String,
     -- geoip lookup result for the probe IP
     `probe_cc` String,
     `probe_asn` UInt32,
@@ -230,4 +231,4 @@ ENGINE = ReplicatedReplacingMergeTree (
         '/clickhouse/{cluster}/tables/ooni/faulty_measurements/{shard}',
         '{replica}'
 )
-ORDER BY (ts, type, probe_cc, probe_asn);
+ORDER BY (ts, type, probe_cc, probe_asn, measurement_uid);

Original file line number	Diff line number	Diff line change
`@@ -220,6 +220,7 @@ CREATE TABLE IF NOT EXISTS faulty_measurements ON CLUSTER oonidata_cluster`
`220`	`220`	`(`
`221`	`221`	`ts` DateTime64(3, 'UTC'),
`222`	`222`	`type` String,
	`223`	+ `measurement_uid` String,
`223`	`224`	`-- geoip lookup result for the probe IP`
`224`	`225`	`probe_cc` String,
`225`	`226`	`probe_asn` UInt32,
`@@ -230,4 +231,4 @@ ENGINE = ReplicatedReplacingMergeTree (`
`230`	`231`	`'/clickhouse/{cluster}/tables/ooni/faulty_measurements/{shard}',`
`231`	`232`	`'{replica}'`
`232`	`233`	`)`
`233`		`-ORDER BY (ts, type, probe_cc, probe_asn);`
	`234`	`+ORDER BY (ts, type, probe_cc, probe_asn, measurement_uid);`