external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

run all joins with repartition

disable_normal_joins
Onder Kalaci 2022-02-23 13:31:23 +01:00
parent 8a2cb07e13
commit 2333cbd908
2 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/backend/distributed/planner/multi_join_order.c
View File

@ -903,6 +903,7 @@ static JoinOrderNode *
LocalJoin(JoinOrderNode *currentJoinNode, TableEntry *candidateTable, LocalJoin(JoinOrderNode *currentJoinNode, TableEntry *candidateTable,
List *applicableJoinClauses, JoinType joinType) List *applicableJoinClauses, JoinType joinType)
{ {
return NULL;
Oid relationId = candidateTable->relationId; Oid relationId = candidateTable->relationId;
uint32 tableId = candidateTable->rangeTableId; uint32 tableId = candidateTable->rangeTableId;
Var *candidatePartitionColumn = PartitionColumn(relationId, tableId); Var *candidatePartitionColumn = PartitionColumn(relationId, tableId);

1
src/test/regress/pg_regress_multi.pl
View File

@ -456,6 +456,7 @@ if ($majorversion >= "14") {
# Citus options set for the tests # Citus options set for the tests
push(@pgOptions, "citus.shard_count=4"); 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.max_adaptive_executor_pool_size=4");
push(@pgOptions, "citus.defer_shard_delete_interval=-1"); push(@pgOptions, "citus.defer_shard_delete_interval=-1");
push(@pgOptions, "citus.repartition_join_bucket_count_per_node=2"); push(@pgOptions, "citus.repartition_join_bucket_count_per_node=2");