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:09:59 +03:00
parent c3748e48e9
commit ecee2d77f2
3 changed files with 140 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/test/regress/multi_mx_schedule
View File

@ -34,7 +34,7 @@ test: multi_mx_add_coordinator
#test: ch_bench_having_mx
#test: recursive_dml_queries_mx multi_mx_truncate_from_worker
test: multi_mx_repartition_udt_prepare
test: multi_mx_repartition_join_w1 multi_mx_repartition_join_w2 multi_mx_repartition_udt_w1 multi_mx_repartition_udt_w2
test: multi_mx_repartition_join_w1 multi_mx_repartition_join_w2 multi_mx_repartition_udt_w1 multi_mx_repartition_udt_w2 connection_count
#test: multi_mx_metadata
#test: master_evaluation master_evaluation_modify master_evaluation_select
#test: multi_mx_call

137
src/test/regress/sql/connection_count.sql Normal file
View File

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

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

@ -184,6 +184,8 @@ INSERT INTO repartition_udt_other values (12, '(2,3)'::test_udt, 'foo');
SET client_min_messages = LOG;
SET citus.task_executor_type = 'task-tracker';
SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-- -- Query that should result in a repartition
-- -- join on int column, and be empty.
-- SELECT * FROM repartition_udt JOIN repartition_udt_other