From 2333cbd908dbc9d4e84ee7722d26cee8979bb301 Mon Sep 17 00:00:00 2001 From: Onder Kalaci Date: Wed, 23 Feb 2022 13:31:23 +0100 Subject: [PATCH] run all joins with repartition --- src/backend/distributed/planner/multi_join_order.c | 1 + src/test/regress/pg_regress_multi.pl | 1 + 2 files changed, 2 insertions(+) diff --git a/src/backend/distributed/planner/multi_join_order.c b/src/backend/distributed/planner/multi_join_order.c index cdfd94cc5..35d3d445b 100644 --- a/src/backend/distributed/planner/multi_join_order.c +++ b/src/backend/distributed/planner/multi_join_order.c @@ -903,6 +903,7 @@ static JoinOrderNode * LocalJoin(JoinOrderNode *currentJoinNode, TableEntry *candidateTable, List *applicableJoinClauses, JoinType joinType) { + return NULL; Oid relationId = candidateTable->relationId; uint32 tableId = candidateTable->rangeTableId; Var *candidatePartitionColumn = PartitionColumn(relationId, tableId); diff --git a/src/test/regress/pg_regress_multi.pl b/src/test/regress/pg_regress_multi.pl index ebbb15371..e77c077ed 100755 --- a/src/test/regress/pg_regress_multi.pl +++ b/src/test/regress/pg_regress_multi.pl @@ -456,6 +456,7 @@ if ($majorversion >= "14") { # Citus options set for the tests push(@pgOptions, "citus.shard_count=4"); +push(@pgOptions, "citus.enable_repartition_joins = on"); push(@pgOptions, "citus.max_adaptive_executor_pool_size=4"); push(@pgOptions, "citus.defer_shard_delete_interval=-1"); push(@pgOptions, "citus.repartition_join_bucket_count_per_node=2");