mirror of https://github.com/citusdata/citus.git
Add a repartition join test for coordinator_shouldhaveshards
parent
7f1e621734
commit
642dcef3e7
|
@ -197,6 +197,15 @@ NOTICE: executing the command locally: SELECT count(*) AS count FROM coordinato
|
||||||
100
|
100
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
|
ROLLBACK;
|
||||||
|
BEGIN;
|
||||||
|
SET citus.enable_repartition_joins TO ON;
|
||||||
|
SELECT count(*) FROM test t1, test t2 WHERE t1.x = t2.y;
|
||||||
|
count
|
||||||
|
---------------------------------------------------------------------
|
||||||
|
100
|
||||||
|
(1 row)
|
||||||
|
|
||||||
ROLLBACK;
|
ROLLBACK;
|
||||||
BEGIN;
|
BEGIN;
|
||||||
SET citus.enable_repartition_joins TO ON;
|
SET citus.enable_repartition_joins TO ON;
|
||||||
|
|
|
@ -87,6 +87,11 @@ SELECT create_distributed_table('dist_table', 'a', colocate_with := 'none');
|
||||||
SELECT count(*) FROM dist_table;
|
SELECT count(*) FROM dist_table;
|
||||||
ROLLBACK;
|
ROLLBACK;
|
||||||
|
|
||||||
|
BEGIN;
|
||||||
|
SET citus.enable_repartition_joins TO ON;
|
||||||
|
SELECT count(*) FROM test t1, test t2 WHERE t1.x = t2.y;
|
||||||
|
ROLLBACK;
|
||||||
|
|
||||||
BEGIN;
|
BEGIN;
|
||||||
SET citus.enable_repartition_joins TO ON;
|
SET citus.enable_repartition_joins TO ON;
|
||||||
-- trigger local execution
|
-- trigger local execution
|
||||||
|
|
Loading…
Reference in New Issue