mirror of https://github.com/citusdata/citus.git
remove task tracker tests from multi mx schedule
parent
d053630be6
commit
03ecc0a681
|
@ -1,15 +0,0 @@
|
||||||
-- Test two concurrent reparttition joins from two different workers
|
|
||||||
-- This test runs the below query from the :worker_1_port and the
|
|
||||||
-- concurrent test runs the same query on :worker_2_port. Note that, both
|
|
||||||
-- 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;
|
|
||||||
CREATE TEMP TABLE t1 AS
|
|
||||||
SELECT
|
|
||||||
l1.l_comment
|
|
||||||
FROM
|
|
||||||
lineitem_mx l1, orders_mx l2
|
|
||||||
WHERE
|
|
||||||
l1.l_comment = l2.o_comment;
|
|
|
@ -1,15 +0,0 @@
|
||||||
-- Test two concurrent reparttition joins from two different workers
|
|
||||||
-- This test runs the below query from the :worker_2_port and the
|
|
||||||
-- concurrent test runs the same query on :worker_1_port. Note that, both
|
|
||||||
-- 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;
|
|
||||||
CREATE TEMP TABLE t1 AS
|
|
||||||
SELECT
|
|
||||||
l1.l_comment
|
|
||||||
FROM
|
|
||||||
lineitem_mx l1, orders_mx l2
|
|
||||||
WHERE
|
|
||||||
l1.l_comment = l2.o_comment;
|
|
|
@ -1,33 +0,0 @@
|
||||||
--
|
|
||||||
-- MULTI_MX_REPARTITION_W1_UDT
|
|
||||||
--
|
|
||||||
\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.log_multi_join_order = true;
|
|
||||||
-- Query that should result in a repartition
|
|
||||||
-- join on int column, and be empty
|
|
||||||
SELECT * FROM repartition_udt JOIN repartition_udt_other
|
|
||||||
ON repartition_udt.pk = repartition_udt_other.pk;
|
|
||||||
LOG: join order: [ "repartition_udt" ][ dual partition join "repartition_udt_other" ]
|
|
||||||
pk | udtcol | txtcol | pk | udtcol | txtcol
|
|
||||||
---------------------------------------------------------------------
|
|
||||||
(0 rows)
|
|
||||||
|
|
||||||
SELECT * FROM repartition_udt JOIN repartition_udt_other
|
|
||||||
ON repartition_udt.udtcol = repartition_udt_other.udtcol
|
|
||||||
WHERE repartition_udt.pk > 1
|
|
||||||
ORDER BY repartition_udt.pk;
|
|
||||||
LOG: join order: [ "repartition_udt" ][ dual partition join "repartition_udt_other" ]
|
|
||||||
pk | udtcol | txtcol | pk | udtcol | txtcol
|
|
||||||
---------------------------------------------------------------------
|
|
||||||
2 | (1,2) | foo | 8 | (1,2) | foo
|
|
||||||
3 | (1,3) | foo | 9 | (1,3) | foo
|
|
||||||
4 | (2,1) | foo | 10 | (2,1) | foo
|
|
||||||
5 | (2,2) | foo | 11 | (2,2) | foo
|
|
||||||
6 | (2,3) | foo | 12 | (2,3) | foo
|
|
||||||
(5 rows)
|
|
||||||
|
|
|
@ -1,33 +0,0 @@
|
||||||
--
|
|
||||||
-- MULTI_MX_REPARTITION_W2_UDT
|
|
||||||
--
|
|
||||||
\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.log_multi_join_order = true;
|
|
||||||
-- Query that should result in a repartition
|
|
||||||
-- join on int column, and be empty.
|
|
||||||
SELECT * FROM repartition_udt JOIN repartition_udt_other
|
|
||||||
ON repartition_udt.pk = repartition_udt_other.pk;
|
|
||||||
LOG: join order: [ "repartition_udt" ][ dual partition join "repartition_udt_other" ]
|
|
||||||
pk | udtcol | txtcol | pk | udtcol | txtcol
|
|
||||||
---------------------------------------------------------------------
|
|
||||||
(0 rows)
|
|
||||||
|
|
||||||
SELECT * FROM repartition_udt JOIN repartition_udt_other
|
|
||||||
ON repartition_udt.udtcol = repartition_udt_other.udtcol
|
|
||||||
WHERE repartition_udt.pk > 1
|
|
||||||
ORDER BY repartition_udt.pk;
|
|
||||||
LOG: join order: [ "repartition_udt" ][ dual partition join "repartition_udt_other" ]
|
|
||||||
pk | udtcol | txtcol | pk | udtcol | txtcol
|
|
||||||
---------------------------------------------------------------------
|
|
||||||
2 | (1,2) | foo | 8 | (1,2) | foo
|
|
||||||
3 | (1,3) | foo | 9 | (1,3) | foo
|
|
||||||
4 | (2,1) | foo | 10 | (2,1) | foo
|
|
||||||
5 | (2,2) | foo | 11 | (2,2) | foo
|
|
||||||
6 | (2,3) | foo | 12 | (2,3) | foo
|
|
||||||
(5 rows)
|
|
||||||
|
|
|
@ -34,7 +34,6 @@ test: multi_mx_tpch_query7_nested multi_mx_ddl
|
||||||
test: ch_bench_having_mx
|
test: ch_bench_having_mx
|
||||||
test: recursive_dml_queries_mx multi_mx_truncate_from_worker
|
test: recursive_dml_queries_mx multi_mx_truncate_from_worker
|
||||||
test: multi_mx_repartition_udt_prepare mx_foreign_key_to_reference_table
|
test: multi_mx_repartition_udt_prepare mx_foreign_key_to_reference_table
|
||||||
test: multi_mx_repartition_join_w1 multi_mx_repartition_join_w2 multi_mx_repartition_udt_w1 multi_mx_repartition_udt_w2
|
|
||||||
test: multi_mx_metadata
|
test: multi_mx_metadata
|
||||||
test: master_evaluation master_evaluation_modify master_evaluation_select
|
test: master_evaluation master_evaluation_modify master_evaluation_select
|
||||||
test: multi_mx_call
|
test: multi_mx_call
|
||||||
|
|
|
@ -1,16 +0,0 @@
|
||||||
-- Test two concurrent reparttition joins from two different workers
|
|
||||||
-- This test runs the below query from the :worker_1_port and the
|
|
||||||
-- concurrent test runs the same query on :worker_2_port. Note that, both
|
|
||||||
-- 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;
|
|
||||||
CREATE TEMP TABLE t1 AS
|
|
||||||
SELECT
|
|
||||||
l1.l_comment
|
|
||||||
FROM
|
|
||||||
lineitem_mx l1, orders_mx l2
|
|
||||||
WHERE
|
|
||||||
l1.l_comment = l2.o_comment;
|
|
|
@ -1,16 +0,0 @@
|
||||||
-- Test two concurrent reparttition joins from two different workers
|
|
||||||
-- This test runs the below query from the :worker_2_port and the
|
|
||||||
-- concurrent test runs the same query on :worker_1_port. Note that, both
|
|
||||||
-- 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;
|
|
||||||
CREATE TEMP TABLE t1 AS
|
|
||||||
SELECT
|
|
||||||
l1.l_comment
|
|
||||||
FROM
|
|
||||||
lineitem_mx l1, orders_mx l2
|
|
||||||
WHERE
|
|
||||||
l1.l_comment = l2.o_comment;
|
|
|
@ -1,21 +0,0 @@
|
||||||
--
|
|
||||||
-- MULTI_MX_REPARTITION_W1_UDT
|
|
||||||
--
|
|
||||||
|
|
||||||
\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.log_multi_join_order = true;
|
|
||||||
|
|
||||||
-- Query that should result in a repartition
|
|
||||||
-- join on int column, and be empty
|
|
||||||
SELECT * FROM repartition_udt JOIN repartition_udt_other
|
|
||||||
ON repartition_udt.pk = repartition_udt_other.pk;
|
|
||||||
|
|
||||||
SELECT * FROM repartition_udt JOIN repartition_udt_other
|
|
||||||
ON repartition_udt.udtcol = repartition_udt_other.udtcol
|
|
||||||
WHERE repartition_udt.pk > 1
|
|
||||||
ORDER BY repartition_udt.pk;
|
|
|
@ -1,21 +0,0 @@
|
||||||
--
|
|
||||||
-- MULTI_MX_REPARTITION_W2_UDT
|
|
||||||
--
|
|
||||||
|
|
||||||
\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.log_multi_join_order = true;
|
|
||||||
|
|
||||||
-- Query that should result in a repartition
|
|
||||||
-- join on int column, and be empty.
|
|
||||||
SELECT * FROM repartition_udt JOIN repartition_udt_other
|
|
||||||
ON repartition_udt.pk = repartition_udt_other.pk;
|
|
||||||
|
|
||||||
SELECT * FROM repartition_udt JOIN repartition_udt_other
|
|
||||||
ON repartition_udt.udtcol = repartition_udt_other.udtcol
|
|
||||||
WHERE repartition_udt.pk > 1
|
|
||||||
ORDER BY repartition_udt.pk;
|
|
Loading…
Reference in New Issue