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

add tests from workers

pull/6259/head
Onder Kalaci 2022-08-31 09:28:16 +03:00
parent e438595d1e
commit f77bc1e9f4
2 changed files with 6 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/test/regress/expected/detect_conn_close.out
View File

@ -147,9 +147,8 @@ ROLLBACK;
-- although should have no difference, we can recover from the failures on the workers as well -- although should have no difference, we can recover from the failures on the workers as well
\c - - - :worker_1_port \c - - - :worker_1_port
SET search_path TO socket_close; SET search_path TO socket_close;
-- now, use 16 connections per worker, we can still recover all connections SET citus.max_adaptive_executor_pool_size TO 1;
SET citus.max_adaptive_executor_pool_size TO 16; SET citus.max_cached_conns_per_worker TO 1;
SET citus.max_cached_conns_per_worker TO 16;
SET citus.force_max_query_parallelization TO ON; SET citus.force_max_query_parallelization TO ON;
SELECT count(*) FROM socket_test_table; SELECT count(*) FROM socket_test_table;
count count
@ -160,8 +159,8 @@ SELECT count(*) FROM socket_test_table;
SELECT result FROM run_command_on_workers($$SELECT count(*) FROM (SELECT pg_terminate_backend(pid) FROM pg_stat_activity WHERE query ilike '%socket_test_table_%' AND query not ilike '%pg_stat_activity%' AND pid !=pg_backend_pid()) as foo$$); SELECT result FROM run_command_on_workers($$SELECT count(*) FROM (SELECT pg_terminate_backend(pid) FROM pg_stat_activity WHERE query ilike '%socket_test_table_%' AND query not ilike '%pg_stat_activity%' AND pid !=pg_backend_pid()) as foo$$);
result result
--------------------------------------------------------------------- ---------------------------------------------------------------------
16 1
16 1
(2 rows) (2 rows)
-- show that none remains -- show that none remains

5
src/test/regress/sql/detect_conn_close.sql
View File

@ -85,9 +85,8 @@ ROLLBACK;
\c - - - :worker_1_port \c - - - :worker_1_port
SET search_path TO socket_close; SET search_path TO socket_close;
-- now, use 16 connections per worker, we can still recover all connections SET citus.max_adaptive_executor_pool_size TO 1;
SET citus.max_adaptive_executor_pool_size TO 16; SET citus.max_cached_conns_per_worker TO 1;
SET citus.max_cached_conns_per_worker TO 16;
SET citus.force_max_query_parallelization TO ON; SET citus.force_max_query_parallelization TO ON;
SELECT count(*) FROM socket_test_table; SELECT count(*) FROM socket_test_table;
SELECT result FROM run_command_on_workers($$SELECT count(*) FROM (SELECT pg_terminate_backend(pid) FROM pg_stat_activity WHERE query ilike '%socket_test_table_%' AND query not ilike '%pg_stat_activity%' AND pid !=pg_backend_pid()) as foo$$); SELECT result FROM run_command_on_workers($$SELECT count(*) FROM (SELECT pg_terminate_backend(pid) FROM pg_stat_activity WHERE query ilike '%socket_test_table_%' AND query not ilike '%pg_stat_activity%' AND pid !=pg_backend_pid()) as foo$$);