From c43c6bfaa0c055f2f4cbe0358e11c113019a736b Mon Sep 17 00:00:00 2001 From: Frank McSherry Date: Tue, 11 Mar 2025 08:08:20 -0400 Subject: [PATCH] Rework join condition to be more clearly an equivalence --- src/catalog/src/builtin.rs | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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