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

test task tracker repartition with replication >1 (#3944)

pull/3946/head
SaitTalhaNisanci 2020-06-24 14:54:20 +03:00 committed by GitHub
parent f458d1fd1c
commit 50e115fe3a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 24 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/test/regress/expected/single_hash_repartition_join.out
View File

@ -510,6 +510,22 @@ SELECT count(*) FROM test_numeric t1 JOIN test_numeric as t2 ON (t1.a = t2.b);
1001 1001
(1 row) (1 row)
SET citus.shard_replication_factor to 2;
CREATE TABLE dist_1 (a int , b int);
SELECT create_distributed_table('dist_1', 'a');
create_distributed_table
---------------------------------------------------------------------
(1 row)
INSERT INTO dist_1 SELECT x,10-x FROM generate_series(1,10) x;
SET citus.task_executor_type to 'task-tracker';
SELECT COUNT(*) FROM dist_1 f, dist_1 s WHERE f.a = s.b;
count
---------------------------------------------------------------------
9
(1 row)
SET client_min_messages TO ERROR; SET client_min_messages TO ERROR;
RESET search_path; RESET search_path;
DROP SCHEMA single_hash_repartition CASCADE; DROP SCHEMA single_hash_repartition CASCADE;

8
src/test/regress/sql/single_hash_repartition_join.sql
View File

@ -146,6 +146,14 @@ SET citus.enable_single_hash_repartition_joins TO ON;
SET citus.enable_repartition_joins TO on; SET citus.enable_repartition_joins TO on;
SELECT count(*) FROM test_numeric t1 JOIN test_numeric as t2 ON (t1.a = t2.b); SELECT count(*) FROM test_numeric t1 JOIN test_numeric as t2 ON (t1.a = t2.b);
SET citus.shard_replication_factor to 2;
CREATE TABLE dist_1 (a int , b int);
SELECT create_distributed_table('dist_1', 'a');
INSERT INTO dist_1 SELECT x,10-x FROM generate_series(1,10) x;
SET citus.task_executor_type to 'task-tracker';
SELECT COUNT(*) FROM dist_1 f, dist_1 s WHERE f.a = s.b;
SET client_min_messages TO ERROR; SET client_min_messages TO ERROR;
RESET search_path; RESET search_path;
DROP SCHEMA single_hash_repartition CASCADE; DROP SCHEMA single_hash_repartition CASCADE;