--
-- MULTI_MX_REPARTITION_W2_UDT
--
\c - - - :worker_2_port
SET client_min_messages = LOG;
-- Query that should result in a repartition join on UDT column.
SET citus.max_adaptive_executor_pool_size TO 1;
SET citus.enable_repartition_joins to ON;
SET citus.log_multi_join_order = true;
-- Query that should result in a repartition
-- join on int column, and be empty.
SELECT * FROM repartition_udt JOIN repartition_udt_other
    ON repartition_udt.pk = repartition_udt_other.pk;
LOG:  join order: [ "repartition_udt" ][ dual partition join "repartition_udt_other" ]
 pk | udtcol | txtcol | pk | udtcol | txtcol
---------------------------------------------------------------------
(0 rows)

SELECT * FROM repartition_udt JOIN repartition_udt_other
    ON repartition_udt.udtcol = repartition_udt_other.udtcol
	WHERE repartition_udt.pk > 1
	ORDER BY repartition_udt.pk;
LOG:  join order: [ "repartition_udt" ][ dual partition join "repartition_udt_other" ]
 pk | udtcol | txtcol | pk | udtcol | txtcol
---------------------------------------------------------------------
  2 | (1,2)  | foo    |  8 | (1,2)  | foo
  3 | (1,3)  | foo    |  9 | (1,3)  | foo
  4 | (2,1)  | foo    | 10 | (2,1)  | foo
  5 | (2,2)  | foo    | 11 | (2,2)  | foo
  6 | (2,3)  | foo    | 12 | (2,3)  | foo
(5 rows)

