-- -- MULTI_REPARTITION_JOIN_PLANNING -- -- Tests that cover repartition join planning. Note that we explicitly start a -- transaction block here so that we don't emit debug messages with changing -- transaction ids in them. SET citus.next_shard_id TO 690000; SET citus.enable_unique_job_ids TO off; SET citus.enable_repartition_joins to ON; SET citus.shard_replication_factor to 1; create schema repartition_join; DROP TABLE IF EXISTS repartition_join.order_line; NOTICE: table "order_line" does not exist, skipping CREATE TABLE order_line ( ol_w_id int NOT NULL, ol_d_id int NOT NULL, ol_o_id int NOT NULL, ol_number int NOT NULL, ol_i_id int NOT NULL, ol_quantity decimal(2,0) NOT NULL, PRIMARY KEY (ol_w_id,ol_d_id,ol_o_id,ol_number) ); DROP TABLE IF EXISTS repartition_join.stock; NOTICE: table "stock" does not exist, skipping CREATE TABLE stock ( s_w_id int NOT NULL, s_i_id int NOT NULL, s_quantity decimal(4,0) NOT NULL, PRIMARY KEY (s_w_id,s_i_id) ); SELECT create_distributed_table('order_line','ol_w_id'); create_distributed_table --------------------------------------------------------------------- (1 row) SELECT create_distributed_table('stock','s_w_id'); create_distributed_table --------------------------------------------------------------------- (1 row) BEGIN; SET client_min_messages TO DEBUG; -- Debug4 log messages display jobIds within them. We explicitly set the jobId -- sequence here so that the regression output becomes independent of the number -- of jobs executed prior to running this test. -- Multi-level repartition join to verify our projection columns are correctly -- referenced and propagated across multiple repartition jobs. The test also -- validates that only the minimal necessary projection columns are transferred -- between jobs. SELECT l_partkey, o_orderkey, count(*) FROM lineitem, part_append, orders, customer_append WHERE l_orderkey = o_orderkey AND l_partkey = p_partkey AND c_custkey = o_custkey AND (l_quantity > 5.0 OR l_extendedprice > 1200.0) AND p_size > 8 AND o_totalprice > 10.0 AND c_acctbal < 5000.0 AND l_partkey < 1000 GROUP BY l_partkey, o_orderkey ORDER BY l_partkey, o_orderkey; DEBUG: Router planner does not support append-partitioned tables. DEBUG: join prunable for intervals [-2147483648,-1] and [0,2147483647] DEBUG: join prunable for intervals [0,2147483647] and [-2147483648,-1] DEBUG: join prunable for task partitionId 0 and 1 DEBUG: join prunable for task partitionId 0 and 2 DEBUG: join prunable for task partitionId 0 and 3 DEBUG: join prunable for task partitionId 0 and 4 DEBUG: join prunable for task partitionId 0 and 5 DEBUG: join prunable for task partitionId 1 and 0 DEBUG: join prunable for task partitionId 1 and 2 DEBUG: join prunable for task partitionId 1 and 3 DEBUG: join prunable for task partitionId 1 and 4 DEBUG: join prunable for task partitionId 1 and 5 DEBUG: join prunable for task partitionId 2 and 0 DEBUG: join prunable for task partitionId 2 and 1 DEBUG: join prunable for task partitionId 2 and 3 DEBUG: join prunable for task partitionId 2 and 4 DEBUG: join prunable for task partitionId 2 and 5 DEBUG: join prunable for task partitionId 3 and 0 DEBUG: join prunable for task partitionId 3 and 1 DEBUG: join prunable for task partitionId 3 and 2 DEBUG: join prunable for task partitionId 3 and 4 DEBUG: join prunable for task partitionId 3 and 5 DEBUG: join prunable for task partitionId 4 and 0 DEBUG: join prunable for task partitionId 4 and 1 DEBUG: join prunable for task partitionId 4 and 2 DEBUG: join prunable for task partitionId 4 and 3 DEBUG: join prunable for task partitionId 4 and 5 DEBUG: join prunable for task partitionId 5 and 0 DEBUG: join prunable for task partitionId 5 and 1 DEBUG: join prunable for task partitionId 5 and 2 DEBUG: join prunable for task partitionId 5 and 3 DEBUG: join prunable for task partitionId 5 and 4 DEBUG: pruning merge fetch taskId 1 DETAIL: Creating dependency on merge taskId 3 DEBUG: pruning merge fetch taskId 2 DETAIL: Creating dependency on merge taskId 3 DEBUG: pruning merge fetch taskId 4 DETAIL: Creating dependency on merge taskId 6 DEBUG: pruning merge fetch taskId 5 DETAIL: Creating dependency on merge taskId 6 DEBUG: pruning merge fetch taskId 7 DETAIL: Creating dependency on merge taskId 9 DEBUG: pruning merge fetch taskId 8 DETAIL: Creating dependency on merge taskId 9 DEBUG: pruning merge fetch taskId 10 DETAIL: Creating dependency on merge taskId 12 DEBUG: pruning merge fetch taskId 11 DETAIL: Creating dependency on merge taskId 12 DEBUG: pruning merge fetch taskId 13 DETAIL: Creating dependency on merge taskId 15 DEBUG: pruning merge fetch taskId 14 DETAIL: Creating dependency on merge taskId 15 DEBUG: pruning merge fetch taskId 16 DETAIL: Creating dependency on merge taskId 18 DEBUG: pruning merge fetch taskId 17 DETAIL: Creating dependency on merge taskId 18 DEBUG: join prunable for task partitionId 0 and 1 DEBUG: join prunable for task partitionId 0 and 2 DEBUG: join prunable for task partitionId 0 and 3 DEBUG: join prunable for task partitionId 0 and 4 DEBUG: join prunable for task partitionId 0 and 5 DEBUG: join prunable for task partitionId 1 and 0 DEBUG: join prunable for task partitionId 1 and 2 DEBUG: join prunable for task partitionId 1 and 3 DEBUG: join prunable for task partitionId 1 and 4 DEBUG: join prunable for task partitionId 1 and 5 DEBUG: join prunable for task partitionId 2 and 0 DEBUG: join prunable for task partitionId 2 and 1 DEBUG: join prunable for task partitionId 2 and 3 DEBUG: join prunable for task partitionId 2 and 4 DEBUG: join prunable for task partitionId 2 and 5 DEBUG: join prunable for task partitionId 3 and 0 DEBUG: join prunable for task partitionId 3 and 1 DEBUG: join prunable for task partitionId 3 and 2 DEBUG: join prunable for task partitionId 3 and 4 DEBUG: join prunable for task partitionId 3 and 5 DEBUG: join prunable for task partitionId 4 and 0 DEBUG: join prunable for task partitionId 4 and 1 DEBUG: join prunable for task partitionId 4 and 2 DEBUG: join prunable for task partitionId 4 and 3 DEBUG: join prunable for task partitionId 4 and 5 DEBUG: join prunable for task partitionId 5 and 0 DEBUG: join prunable for task partitionId 5 and 1 DEBUG: join prunable for task partitionId 5 and 2 DEBUG: join prunable for task partitionId 5 and 3 DEBUG: join prunable for task partitionId 5 and 4 DEBUG: pruning merge fetch taskId 1 DETAIL: Creating dependency on merge taskId 19 DEBUG: pruning merge fetch taskId 2 DETAIL: Creating dependency on merge taskId 4 DEBUG: pruning merge fetch taskId 4 DETAIL: Creating dependency on merge taskId 26 DEBUG: pruning merge fetch taskId 5 DETAIL: Creating dependency on merge taskId 8 DEBUG: pruning merge fetch taskId 7 DETAIL: Creating dependency on merge taskId 33 DEBUG: pruning merge fetch taskId 8 DETAIL: Creating dependency on merge taskId 12 DEBUG: pruning merge fetch taskId 10 DETAIL: Creating dependency on merge taskId 40 DEBUG: pruning merge fetch taskId 11 DETAIL: Creating dependency on merge taskId 16 DEBUG: pruning merge fetch taskId 13 DETAIL: Creating dependency on merge taskId 47 DEBUG: pruning merge fetch taskId 14 DETAIL: Creating dependency on merge taskId 20 DEBUG: pruning merge fetch taskId 16 DETAIL: Creating dependency on merge taskId 54 DEBUG: pruning merge fetch taskId 17 DETAIL: Creating dependency on merge taskId 24 l_partkey | o_orderkey | count --------------------------------------------------------------------- 18 | 12005 | 1 79 | 5121 | 1 91 | 2883 | 1 222 | 9413 | 1 278 | 1287 | 1 309 | 2374 | 1 318 | 321 | 1 321 | 5984 | 1 337 | 10403 | 1 350 | 13698 | 1 358 | 4323 | 1 364 | 9347 | 1 416 | 640 | 1 426 | 10855 | 1 450 | 35 | 1 484 | 3843 | 1 504 | 14566 | 1 510 | 13569 | 1 532 | 3175 | 1 641 | 134 | 1 669 | 10944 | 1 716 | 2885 | 1 738 | 4355 | 1 802 | 2534 | 1 824 | 9287 | 1 864 | 3175 | 1 957 | 4293 | 1 960 | 10980 | 1 963 | 4580 | 1 (29 rows) SELECT l_partkey, o_orderkey, count(*) FROM lineitem, orders WHERE l_suppkey = o_shippriority AND l_quantity < 5.0 AND o_totalprice <> 4.0 GROUP BY l_partkey, o_orderkey ORDER BY l_partkey, o_orderkey; DEBUG: Router planner cannot handle multi-shard select queries DEBUG: join prunable for task partitionId 0 and 1 DEBUG: join prunable for task partitionId 0 and 2 DEBUG: join prunable for task partitionId 0 and 3 DEBUG: join prunable for task partitionId 0 and 4 DEBUG: join prunable for task partitionId 0 and 5 DEBUG: join prunable for task partitionId 1 and 0 DEBUG: join prunable for task partitionId 1 and 2 DEBUG: join prunable for task partitionId 1 and 3 DEBUG: join prunable for task partitionId 1 and 4 DEBUG: join prunable for task partitionId 1 and 5 DEBUG: join prunable for task partitionId 2 and 0 DEBUG: join prunable for task partitionId 2 and 1 DEBUG: join prunable for task partitionId 2 and 3 DEBUG: join prunable for task partitionId 2 and 4 DEBUG: join prunable for task partitionId 2 and 5 DEBUG: join prunable for task partitionId 3 and 0 DEBUG: join prunable for task partitionId 3 and 1 DEBUG: join prunable for task partitionId 3 and 2 DEBUG: join prunable for task partitionId 3 and 4 DEBUG: join prunable for task partitionId 3 and 5 DEBUG: join prunable for task partitionId 4 and 0 DEBUG: join prunable for task partitionId 4 and 1 DEBUG: join prunable for task partitionId 4 and 2 DEBUG: join prunable for task partitionId 4 and 3 DEBUG: join prunable for task partitionId 4 and 5 DEBUG: join prunable for task partitionId 5 and 0 DEBUG: join prunable for task partitionId 5 and 1 DEBUG: join prunable for task partitionId 5 and 2 DEBUG: join prunable for task partitionId 5 and 3 DEBUG: join prunable for task partitionId 5 and 4 DEBUG: pruning merge fetch taskId 1 DETAIL: Creating dependency on merge taskId 3 DEBUG: pruning merge fetch taskId 2 DETAIL: Creating dependency on merge taskId 3 DEBUG: pruning merge fetch taskId 4 DETAIL: Creating dependency on merge taskId 6 DEBUG: pruning merge fetch taskId 5 DETAIL: Creating dependency on merge taskId 6 DEBUG: pruning merge fetch taskId 7 DETAIL: Creating dependency on merge taskId 9 DEBUG: pruning merge fetch taskId 8 DETAIL: Creating dependency on merge taskId 9 DEBUG: pruning merge fetch taskId 10 DETAIL: Creating dependency on merge taskId 12 DEBUG: pruning merge fetch taskId 11 DETAIL: Creating dependency on merge taskId 12 DEBUG: pruning merge fetch taskId 13 DETAIL: Creating dependency on merge taskId 15 DEBUG: pruning merge fetch taskId 14 DETAIL: Creating dependency on merge taskId 15 DEBUG: pruning merge fetch taskId 16 DETAIL: Creating dependency on merge taskId 18 DEBUG: pruning merge fetch taskId 17 DETAIL: Creating dependency on merge taskId 18 l_partkey | o_orderkey | count --------------------------------------------------------------------- (0 rows) -- Check that grouping by primary key allows o_shippriority to be in the target list SELECT o_orderkey, o_shippriority, count(*) FROM lineitem, orders WHERE l_suppkey = o_shippriority GROUP BY o_orderkey ORDER BY o_orderkey; DEBUG: Router planner cannot handle multi-shard select queries DEBUG: join prunable for task partitionId 0 and 1 DEBUG: join prunable for task partitionId 0 and 2 DEBUG: join prunable for task partitionId 0 and 3 DEBUG: join prunable for task partitionId 0 and 4 DEBUG: join prunable for task partitionId 0 and 5 DEBUG: join prunable for task partitionId 1 and 0 DEBUG: join prunable for task partitionId 1 and 2 DEBUG: join prunable for task partitionId 1 and 3 DEBUG: join prunable for task partitionId 1 and 4 DEBUG: join prunable for task partitionId 1 and 5 DEBUG: join prunable for task partitionId 2 and 0 DEBUG: join prunable for task partitionId 2 and 1 DEBUG: join prunable for task partitionId 2 and 3 DEBUG: join prunable for task partitionId 2 and 4 DEBUG: join prunable for task partitionId 2 and 5 DEBUG: join prunable for task partitionId 3 and 0 DEBUG: join prunable for task partitionId 3 and 1 DEBUG: join prunable for task partitionId 3 and 2 DEBUG: join prunable for task partitionId 3 and 4 DEBUG: join prunable for task partitionId 3 and 5 DEBUG: join prunable for task partitionId 4 and 0 DEBUG: join prunable for task partitionId 4 and 1 DEBUG: join prunable for task partitionId 4 and 2 DEBUG: join prunable for task partitionId 4 and 3 DEBUG: join prunable for task partitionId 4 and 5 DEBUG: join prunable for task partitionId 5 and 0 DEBUG: join prunable for task partitionId 5 and 1 DEBUG: join prunable for task partitionId 5 and 2 DEBUG: join prunable for task partitionId 5 and 3 DEBUG: join prunable for task partitionId 5 and 4 DEBUG: pruning merge fetch taskId 1 DETAIL: Creating dependency on merge taskId 3 DEBUG: pruning merge fetch taskId 2 DETAIL: Creating dependency on merge taskId 3 DEBUG: pruning merge fetch taskId 4 DETAIL: Creating dependency on merge taskId 6 DEBUG: pruning merge fetch taskId 5 DETAIL: Creating dependency on merge taskId 6 DEBUG: pruning merge fetch taskId 7 DETAIL: Creating dependency on merge taskId 9 DEBUG: pruning merge fetch taskId 8 DETAIL: Creating dependency on merge taskId 9 DEBUG: pruning merge fetch taskId 10 DETAIL: Creating dependency on merge taskId 12 DEBUG: pruning merge fetch taskId 11 DETAIL: Creating dependency on merge taskId 12 DEBUG: pruning merge fetch taskId 13 DETAIL: Creating dependency on merge taskId 15 DEBUG: pruning merge fetch taskId 14 DETAIL: Creating dependency on merge taskId 15 DEBUG: pruning merge fetch taskId 16 DETAIL: Creating dependency on merge taskId 18 DEBUG: pruning merge fetch taskId 17 DETAIL: Creating dependency on merge taskId 18 o_orderkey | o_shippriority | count --------------------------------------------------------------------- (0 rows) -- Check that grouping by primary key allows o_shippriority to be in the target -- list -- Postgres removes o_shippriority from the group by clause here SELECT o_orderkey, o_shippriority, count(*) FROM lineitem, orders WHERE l_suppkey = o_shippriority GROUP BY o_orderkey, o_shippriority ORDER BY o_orderkey; DEBUG: Router planner cannot handle multi-shard select queries DEBUG: join prunable for task partitionId 0 and 1 DEBUG: join prunable for task partitionId 0 and 2 DEBUG: join prunable for task partitionId 0 and 3 DEBUG: join prunable for task partitionId 0 and 4 DEBUG: join prunable for task partitionId 0 and 5 DEBUG: join prunable for task partitionId 1 and 0 DEBUG: join prunable for task partitionId 1 and 2 DEBUG: join prunable for task partitionId 1 and 3 DEBUG: join prunable for task partitionId 1 and 4 DEBUG: join prunable for task partitionId 1 and 5 DEBUG: join prunable for task partitionId 2 and 0 DEBUG: join prunable for task partitionId 2 and 1 DEBUG: join prunable for task partitionId 2 and 3 DEBUG: join prunable for task partitionId 2 and 4 DEBUG: join prunable for task partitionId 2 and 5 DEBUG: join prunable for task partitionId 3 and 0 DEBUG: join prunable for task partitionId 3 and 1 DEBUG: join prunable for task partitionId 3 and 2 DEBUG: join prunable for task partitionId 3 and 4 DEBUG: join prunable for task partitionId 3 and 5 DEBUG: join prunable for task partitionId 4 and 0 DEBUG: join prunable for task partitionId 4 and 1 DEBUG: join prunable for task partitionId 4 and 2 DEBUG: join prunable for task partitionId 4 and 3 DEBUG: join prunable for task partitionId 4 and 5 DEBUG: join prunable for task partitionId 5 and 0 DEBUG: join prunable for task partitionId 5 and 1 DEBUG: join prunable for task partitionId 5 and 2 DEBUG: join prunable for task partitionId 5 and 3 DEBUG: join prunable for task partitionId 5 and 4 DEBUG: pruning merge fetch taskId 1 DETAIL: Creating dependency on merge taskId 3 DEBUG: pruning merge fetch taskId 2 DETAIL: Creating dependency on merge taskId 3 DEBUG: pruning merge fetch taskId 4 DETAIL: Creating dependency on merge taskId 6 DEBUG: pruning merge fetch taskId 5 DETAIL: Creating dependency on merge taskId 6 DEBUG: pruning merge fetch taskId 7 DETAIL: Creating dependency on merge taskId 9 DEBUG: pruning merge fetch taskId 8 DETAIL: Creating dependency on merge taskId 9 DEBUG: pruning merge fetch taskId 10 DETAIL: Creating dependency on merge taskId 12 DEBUG: pruning merge fetch taskId 11 DETAIL: Creating dependency on merge taskId 12 DEBUG: pruning merge fetch taskId 13 DETAIL: Creating dependency on merge taskId 15 DEBUG: pruning merge fetch taskId 14 DETAIL: Creating dependency on merge taskId 15 DEBUG: pruning merge fetch taskId 16 DETAIL: Creating dependency on merge taskId 18 DEBUG: pruning merge fetch taskId 17 DETAIL: Creating dependency on merge taskId 18 o_orderkey | o_shippriority | count --------------------------------------------------------------------- (0 rows) -- Check that calling any_value manually works as well SELECT o_orderkey, any_value(o_shippriority) FROM lineitem, orders WHERE l_suppkey = o_shippriority GROUP BY o_orderkey, o_shippriority ORDER BY o_orderkey; DEBUG: Router planner cannot handle multi-shard select queries DEBUG: join prunable for task partitionId 0 and 1 DEBUG: join prunable for task partitionId 0 and 2 DEBUG: join prunable for task partitionId 0 and 3 DEBUG: join prunable for task partitionId 0 and 4 DEBUG: join prunable for task partitionId 0 and 5 DEBUG: join prunable for task partitionId 1 and 0 DEBUG: join prunable for task partitionId 1 and 2 DEBUG: join prunable for task partitionId 1 and 3 DEBUG: join prunable for task partitionId 1 and 4 DEBUG: join prunable for task partitionId 1 and 5 DEBUG: join prunable for task partitionId 2 and 0 DEBUG: join prunable for task partitionId 2 and 1 DEBUG: join prunable for task partitionId 2 and 3 DEBUG: join prunable for task partitionId 2 and 4 DEBUG: join prunable for task partitionId 2 and 5 DEBUG: join prunable for task partitionId 3 and 0 DEBUG: join prunable for task partitionId 3 and 1 DEBUG: join prunable for task partitionId 3 and 2 DEBUG: join prunable for task partitionId 3 and 4 DEBUG: join prunable for task partitionId 3 and 5 DEBUG: join prunable for task partitionId 4 and 0 DEBUG: join prunable for task partitionId 4 and 1 DEBUG: join prunable for task partitionId 4 and 2 DEBUG: join prunable for task partitionId 4 and 3 DEBUG: join prunable for task partitionId 4 and 5 DEBUG: join prunable for task partitionId 5 and 0 DEBUG: join prunable for task partitionId 5 and 1 DEBUG: join prunable for task partitionId 5 and 2 DEBUG: join prunable for task partitionId 5 and 3 DEBUG: join prunable for task partitionId 5 and 4 DEBUG: pruning merge fetch taskId 1 DETAIL: Creating dependency on merge taskId 3 DEBUG: pruning merge fetch taskId 2 DETAIL: Creating dependency on merge taskId 3 DEBUG: pruning merge fetch taskId 4 DETAIL: Creating dependency on merge taskId 6 DEBUG: pruning merge fetch taskId 5 DETAIL: Creating dependency on merge taskId 6 DEBUG: pruning merge fetch taskId 7 DETAIL: Creating dependency on merge taskId 9 DEBUG: pruning merge fetch taskId 8 DETAIL: Creating dependency on merge taskId 9 DEBUG: pruning merge fetch taskId 10 DETAIL: Creating dependency on merge taskId 12 DEBUG: pruning merge fetch taskId 11 DETAIL: Creating dependency on merge taskId 12 DEBUG: pruning merge fetch taskId 13 DETAIL: Creating dependency on merge taskId 15 DEBUG: pruning merge fetch taskId 14 DETAIL: Creating dependency on merge taskId 15 DEBUG: pruning merge fetch taskId 16 DETAIL: Creating dependency on merge taskId 18 DEBUG: pruning merge fetch taskId 17 DETAIL: Creating dependency on merge taskId 18 o_orderkey | any_value --------------------------------------------------------------------- (0 rows) -- Check that grouping by primary key allows s_quantity to be in the having -- list -- Postgres removes s_quantity from the group by clause here select s_i_id from stock, order_line where ol_i_id=s_i_id group by s_i_id, s_w_id, s_quantity having s_quantity > random() ; DEBUG: Router planner cannot handle multi-shard select queries DEBUG: join prunable for task partitionId 0 and 1 DEBUG: join prunable for task partitionId 0 and 2 DEBUG: join prunable for task partitionId 0 and 3 DEBUG: join prunable for task partitionId 0 and 4 DEBUG: join prunable for task partitionId 0 and 5 DEBUG: join prunable for task partitionId 1 and 0 DEBUG: join prunable for task partitionId 1 and 2 DEBUG: join prunable for task partitionId 1 and 3 DEBUG: join prunable for task partitionId 1 and 4 DEBUG: join prunable for task partitionId 1 and 5 DEBUG: join prunable for task partitionId 2 and 0 DEBUG: join prunable for task partitionId 2 and 1 DEBUG: join prunable for task partitionId 2 and 3 DEBUG: join prunable for task partitionId 2 and 4 DEBUG: join prunable for task partitionId 2 and 5 DEBUG: join prunable for task partitionId 3 and 0 DEBUG: join prunable for task partitionId 3 and 1 DEBUG: join prunable for task partitionId 3 and 2 DEBUG: join prunable for task partitionId 3 and 4 DEBUG: join prunable for task partitionId 3 and 5 DEBUG: join prunable for task partitionId 4 and 0 DEBUG: join prunable for task partitionId 4 and 1 DEBUG: join prunable for task partitionId 4 and 2 DEBUG: join prunable for task partitionId 4 and 3 DEBUG: join prunable for task partitionId 4 and 5 DEBUG: join prunable for task partitionId 5 and 0 DEBUG: join prunable for task partitionId 5 and 1 DEBUG: join prunable for task partitionId 5 and 2 DEBUG: join prunable for task partitionId 5 and 3 DEBUG: join prunable for task partitionId 5 and 4 DEBUG: pruning merge fetch taskId 1 DETAIL: Creating dependency on merge taskId 5 DEBUG: pruning merge fetch taskId 2 DETAIL: Creating dependency on merge taskId 5 DEBUG: pruning merge fetch taskId 4 DETAIL: Creating dependency on merge taskId 10 DEBUG: pruning merge fetch taskId 5 DETAIL: Creating dependency on merge taskId 10 DEBUG: pruning merge fetch taskId 7 DETAIL: Creating dependency on merge taskId 15 DEBUG: pruning merge fetch taskId 8 DETAIL: Creating dependency on merge taskId 15 DEBUG: pruning merge fetch taskId 10 DETAIL: Creating dependency on merge taskId 20 DEBUG: pruning merge fetch taskId 11 DETAIL: Creating dependency on merge taskId 20 DEBUG: pruning merge fetch taskId 13 DETAIL: Creating dependency on merge taskId 25 DEBUG: pruning merge fetch taskId 14 DETAIL: Creating dependency on merge taskId 25 DEBUG: pruning merge fetch taskId 16 DETAIL: Creating dependency on merge taskId 30 DEBUG: pruning merge fetch taskId 17 DETAIL: Creating dependency on merge taskId 30 s_i_id --------------------------------------------------------------------- (0 rows) -- Reset client logging level to its previous value SET client_min_messages TO NOTICE; COMMIT; drop schema repartition_join;