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

test

test/adaptive_executor_repartition
Sait Talha Nisanci 2020-07-03 15:24:43 +03:00
parent ecee2d77f2
commit 2a011164f2
4 changed files with 85 additions and 83 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
.circleci/config.yml
View File

@ -292,27 +292,27 @@ workflows:
- check-style - check-style
- check-sql-snapshots - check-sql-snapshots
- test-11_check-multi: # - test-11_check-multi:
requires: [build] # requires: [build]
- test-11_check-tt-van-mx: - test-11_check-tt-van-mx:
requires: [build] requires: [build]
- test-11_check-iso-work-fol: # - test-11_check-iso-work-fol:
requires: [build] # requires: [build]
- test-11_check-fol: # - test-11_check-fol:
requires: [build] # requires: [build]
- test-11_check-failure: # - test-11_check-failure:
requires: [build] # requires: [build]
- test-12_check-multi: # - test-12_check-multi:
requires: [build] # requires: [build]
- test-12_check-tt-van-mx: - test-12_check-tt-van-mx:
requires: [build] requires: [build]
- test-12_check-iso-work-fol: # - test-12_check-iso-work-fol:
requires: [build] # requires: [build]
- test-12_check-fol: # - test-12_check-fol:
requires: [build] # requires: [build]
- test-12_check-failure: # - test-12_check-failure:
requires: [build] # requires: [build]
- test-11-12_check-pg-upgrade: - test-11-12_check-pg-upgrade:
requires: [build] requires: [build]

133
src/test/regress/sql/connection_count.sql
View File

@ -1,137 +1,136 @@
select pg_sleep(0.05);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
select pg_sleep(0.05); select pg_sleep(0.01);

2
src/test/regress/sql/multi_mx_repartition_udt_w1.sql
View File

@ -1,6 +1,7 @@
-- --
-- MULTI_MX_REPARTITION_W1_UDT -- MULTI_MX_REPARTITION_W1_UDT
-- --
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
\c - - - :worker_1_port \c - - - :worker_1_port
SET client_min_messages = LOG; SET client_min_messages = LOG;
@ -10,6 +11,7 @@ SET citus.enable_repartition_joins to ON;
SET citus.task_executor_type = 'adaptive'; SET citus.task_executor_type = 'adaptive';
SET citus.log_multi_join_order = true; SET citus.log_multi_join_order = true;
-- Query that should result in a repartition -- Query that should result in a repartition
-- join on int column, and be empty -- join on int column, and be empty
SELECT * FROM repartition_udt JOIN repartition_udt_other SELECT * FROM repartition_udt JOIN repartition_udt_other

1
src/test/regress/sql/multi_mx_repartition_udt_w2.sql
View File

@ -1,6 +1,7 @@
-- --
-- MULTI_MX_REPARTITION_W2_UDT -- MULTI_MX_REPARTITION_W2_UDT
-- --
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
\c - - - :worker_2_port \c - - - :worker_2_port
SET client_min_messages = LOG; SET client_min_messages = LOG;