From 50e115fe3a4b84f3023f881be25bd61a61175950 Mon Sep 17 00:00:00 2001 From: SaitTalhaNisanci Date: Wed, 24 Jun 2020 14:54:20 +0300 Subject: [PATCH] test task tracker repartition with replication >1 (#3944) --- .../expected/single_hash_repartition_join.out | 16 ++++++++++++++++ .../regress/sql/single_hash_repartition_join.sql | 8 ++++++++ 2 files changed, 24 insertions(+) diff --git a/src/test/regress/expected/single_hash_repartition_join.out b/src/test/regress/expected/single_hash_repartition_join.out index 4cff51e38..182dab1d2 100644 --- a/src/test/regress/expected/single_hash_repartition_join.out +++ b/src/test/regress/expected/single_hash_repartition_join.out @@ -510,6 +510,22 @@ SELECT count(*) FROM test_numeric t1 JOIN test_numeric as t2 ON (t1.a = t2.b); 1001 (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; RESET search_path; DROP SCHEMA single_hash_repartition CASCADE; diff --git a/src/test/regress/sql/single_hash_repartition_join.sql b/src/test/regress/sql/single_hash_repartition_join.sql index d18da5268..8bcf77c68 100644 --- a/src/test/regress/sql/single_hash_repartition_join.sql +++ b/src/test/regress/sql/single_hash_repartition_join.sql @@ -146,6 +146,14 @@ SET citus.enable_single_hash_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); +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; RESET search_path; DROP SCHEMA single_hash_repartition CASCADE;