test parallel repartition joins with adaptive

test/adaptive_executor_repartition
Sait Talha Nisanci 2020-07-03 10:46:24 +03:00
parent 14c6861e5d
commit 453d2d2b66
4 changed files with 12 additions and 4 deletions

View File

@ -4,7 +4,9 @@
-- tests use the same sequence ids but the queries should not fail.
\c - - - :worker_1_port
SET citus.task_executor_type TO "task-tracker";
SET citus.max_adaptive_executor_pool_size TO 2;
SET citus.enable_repartition_joins to ON;
SET citus.task_executor_type = 'adaptive';
CREATE TEMP TABLE t1 AS
SELECT
l1.l_comment

View File

@ -4,7 +4,9 @@
-- tests use the same sequence ids but the queries should not fail.
\c - - - :worker_2_port
SET citus.task_executor_type TO "task-tracker";
SET citus.max_adaptive_executor_pool_size TO 2;
SET citus.enable_repartition_joins to ON;
SET citus.task_executor_type = 'adaptive';
CREATE TEMP TABLE t1 AS
SELECT
l1.l_comment

View File

@ -5,7 +5,9 @@
\c - - - :worker_1_port
SET client_min_messages = LOG;
-- Query that should result in a repartition join on UDT column.
SET citus.task_executor_type = 'task-tracker';
SET citus.max_adaptive_executor_pool_size TO 2;
SET citus.enable_repartition_joins to ON;
SET citus.task_executor_type = 'adaptive';
SET citus.log_multi_join_order = true;
-- Query that should result in a repartition

View File

@ -5,7 +5,9 @@
\c - - - :worker_2_port
SET client_min_messages = LOG;
-- Query that should result in a repartition join on UDT column.
SET citus.task_executor_type = 'task-tracker';
SET citus.max_adaptive_executor_pool_size TO 2;
SET citus.enable_repartition_joins to ON;
SET citus.task_executor_type = 'adaptive';
SET citus.log_multi_join_order = true;
-- Query that should result in a repartition