diff --git a/src/catalog/src/builtin.rs b/src/catalog/src/builtin.rs index 1b728100a820c..11baad09d77ca 100644 --- a/src/catalog/src/builtin.rs +++ b/src/catalog/src/builtin.rs @@ -5617,9 +5617,10 @@ FROM mz_introspection.mz_dataflow_addresses_per_worker addr1, mz_introspection.mz_dataflow_addresses_per_worker addr2 WHERE + addr2.address = CASE - WHEN source = 0 THEN addr2.address = addr1.address - ELSE addr2.address = addr1.address || reachability.source + WHEN source = 0 THEN addr1.address + ELSE addr1.address || reachability.source END AND addr1.id = reachability.id AND addr1.worker_id = reachability.worker_id