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

Improve regression test settings

pull/4370/head
Marco Slot 2020-11-30 09:49:10 +01:00
parent cc9ea31c60
commit 48caca4084
3 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/test/regress/expected/shared_connection_stats.out
View File

@ -226,6 +226,7 @@ COMMIT;
-- now, some of the optional connections would be skipped, -- now, some of the optional connections would be skipped,
-- and only 5 connections are used per node -- and only 5 connections are used per node
BEGIN; BEGIN;
SET LOCAL citus.max_adaptive_executor_pool_size TO 16;
SELECT count(*), pg_sleep(0.1) FROM test; SELECT count(*), pg_sleep(0.1) FROM test;
count | pg_sleep count | pg_sleep
--------------------------------------------------------------------- ---------------------------------------------------------------------
@ -476,6 +477,7 @@ BEGIN;
-- when COPY is used with _max_query_parallelization -- when COPY is used with _max_query_parallelization
-- it ignores the shared pool size -- it ignores the shared pool size
SET LOCAL citus.force_max_query_parallelization TO ON; SET LOCAL citus.force_max_query_parallelization TO ON;
SET LOCAL citus.max_adaptive_executor_pool_size TO 16;
COPY test FROM PROGRAM 'seq 32'; COPY test FROM PROGRAM 'seq 32';
SELECT SELECT
connection_count_to_node connection_count_to_node

4
src/test/regress/pg_regress_multi.pl
View File

@ -415,11 +415,15 @@ push(@pgOptions, "shared_preload_libraries='${sharedPreloadLibraries}'");
# Avoid parallelism to stabilize explain plans # Avoid parallelism to stabilize explain plans
push(@pgOptions, "max_parallel_workers_per_gather=0"); push(@pgOptions, "max_parallel_workers_per_gather=0");
# Help with debugging
push(@pgOptions, "log_error_verbosity = 'verbose'");
# Allow CREATE SUBSCRIPTION to work # Allow CREATE SUBSCRIPTION to work
push(@pgOptions, "wal_level='logical'"); push(@pgOptions, "wal_level='logical'");
# Citus options set for the tests # Citus options set for the tests
push(@pgOptions, "citus.shard_count=4"); push(@pgOptions, "citus.shard_count=4");
push(@pgOptions, "citus.max_adaptive_executor_pool_size=4");
push(@pgOptions, "citus.shard_max_size=1500kB"); push(@pgOptions, "citus.shard_max_size=1500kB");
push(@pgOptions, "citus.repartition_join_bucket_count_per_node=2"); push(@pgOptions, "citus.repartition_join_bucket_count_per_node=2");
push(@pgOptions, "citus.sort_returning='on'"); push(@pgOptions, "citus.sort_returning='on'");

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

@ -148,6 +148,7 @@ COMMIT;
-- now, some of the optional connections would be skipped, -- now, some of the optional connections would be skipped,
-- and only 5 connections are used per node -- and only 5 connections are used per node
BEGIN; BEGIN;
SET LOCAL citus.max_adaptive_executor_pool_size TO 16;
SELECT count(*), pg_sleep(0.1) FROM test; SELECT count(*), pg_sleep(0.1) FROM test;
SELECT SELECT
connection_count_to_node connection_count_to_node
@ -325,6 +326,7 @@ BEGIN;
-- when COPY is used with _max_query_parallelization -- when COPY is used with _max_query_parallelization
-- it ignores the shared pool size -- it ignores the shared pool size
SET LOCAL citus.force_max_query_parallelization TO ON; SET LOCAL citus.force_max_query_parallelization TO ON;
SET LOCAL citus.max_adaptive_executor_pool_size TO 16;
COPY test FROM PROGRAM 'seq 32'; COPY test FROM PROGRAM 'seq 32';
SELECT SELECT