more consistent test output

pull/5334/head
Nils Dijk 2021-10-21 18:21:41 +02:00
parent 34b88e111a
commit 63268b61a8
No known key found for this signature in database
GPG Key ID: CA1177EF9434F241
2 changed files with 2 additions and 3 deletions

View File

@ -9,6 +9,7 @@ SELECT pg_backend_pid() as pid \gset
SET citus.next_shard_id TO 4213581; SET citus.next_shard_id TO 4213581;
SET citus.shard_count TO 4; SET citus.shard_count TO 4;
SET citus.shard_replication_factor TO 2; SET citus.shard_replication_factor TO 2;
SET citus.max_adaptive_executor_pool_size TO 1; -- have more consistent number of connections running
CREATE TABLE replicated_source_table(a int, b int); CREATE TABLE replicated_source_table(a int, b int);
SELECT create_distributed_table('replicated_source_table', 'a'); SELECT create_distributed_table('replicated_source_table', 'a');
create_distributed_table create_distributed_table
@ -69,9 +70,6 @@ SELECT citus.mitmproxy('conn.onQuery(query="worker_partition_query_result").kill
(1 row) (1 row)
INSERT INTO target_table SELECT * FROM replicated_source_table; INSERT INTO target_table SELECT * FROM replicated_source_table;
WARNING: connection to the remote node localhost:xxxxx failed with the following error: server closed the connection unexpectedly
This probably means the server terminated abnormally
before or while processing the request.
WARNING: connection to the remote node localhost:xxxxx failed with the following error: server closed the connection unexpectedly WARNING: connection to the remote node localhost:xxxxx failed with the following error: server closed the connection unexpectedly
This probably means the server terminated abnormally This probably means the server terminated abnormally
before or while processing the request. before or while processing the request.

View File

@ -12,6 +12,7 @@ SET citus.next_shard_id TO 4213581;
SET citus.shard_count TO 4; SET citus.shard_count TO 4;
SET citus.shard_replication_factor TO 2; SET citus.shard_replication_factor TO 2;
SET citus.max_adaptive_executor_pool_size TO 1; -- have more consistent number of connections running
CREATE TABLE replicated_source_table(a int, b int); CREATE TABLE replicated_source_table(a int, b int);
SELECT create_distributed_table('replicated_source_table', 'a'); SELECT create_distributed_table('replicated_source_table', 'a');
INSERT INTO replicated_source_table SELECT i, i*i FROM generate_series(1, 10) i; INSERT INTO replicated_source_table SELECT i, i*i FROM generate_series(1, 10) i;