mirror of https://github.com/citusdata/citus.git
Disable implicit single re-partition joins for append tables
parent
2206e64e42
commit
dfad73d918
|
@ -1020,7 +1020,7 @@ SinglePartitionJoin(JoinOrderNode *currentJoinNode, TableEntry *candidateTable,
|
||||||
currentPartitionMethod,
|
currentPartitionMethod,
|
||||||
currentAnchorTable);
|
currentAnchorTable);
|
||||||
}
|
}
|
||||||
else
|
else if (candidatePartitionMethod == DISTRIBUTE_BY_RANGE)
|
||||||
{
|
{
|
||||||
return MakeJoinOrderNode(candidateTable, SINGLE_RANGE_PARTITION_JOIN,
|
return MakeJoinOrderNode(candidateTable, SINGLE_RANGE_PARTITION_JOIN,
|
||||||
currentPartitionColumnList,
|
currentPartitionColumnList,
|
||||||
|
|
|
@ -41,7 +41,7 @@ SET citus.shard_replication_factor to 1;
|
||||||
-- for interval [8,10] repartition join logic will be triggered.
|
-- for interval [8,10] repartition join logic will be triggered.
|
||||||
SET citus.enable_repartition_joins to ON;
|
SET citus.enable_repartition_joins to ON;
|
||||||
SELECT count(*) FROM test_table_1, test_table_2 WHERE test_table_1.id = test_table_2.id;
|
SELECT count(*) FROM test_table_1, test_table_2 WHERE test_table_1.id = test_table_2.id;
|
||||||
LOG: join order: [ "test_table_1" ][ single range partition join "test_table_2" ]
|
LOG: join order: [ "test_table_1" ][ dual partition join "test_table_2" ]
|
||||||
count
|
count
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
9
|
9
|
||||||
|
|
Loading…
Reference in New Issue