diff --git a/src/test/regress/expected/insert_select_connection_leak.out b/src/test/regress/expected/insert_select_connection_leak.out index a971c608e..8a983acd5 100644 --- a/src/test/regress/expected/insert_select_connection_leak.out +++ b/src/test/regress/expected/insert_select_connection_leak.out @@ -23,7 +23,7 @@ SELECT create_distributed_table('target_table', 'a'); (1 row) -INSERT INTO source_table SELECT i, 2 * i FROM generate_series(1, 10000) i; +INSERT INTO source_table SELECT i, 2 * i FROM generate_series(1, 100) i; EXPLAIN (costs off) INSERT INTO target_table SELECT * FROM source_table; QUERY PLAN --------------------------------------------------------------------- @@ -81,7 +81,7 @@ INSERT INTO target_table SELECT * FROM source_table; SELECT worker_connection_count(:worker_1_port) AS worker_1_connections, worker_connection_count(:worker_2_port) AS worker_2_connections \gset SAVEPOINT s1; -INSERT INTO target_table SELECT a, CASE WHEN a < 5000 THEN b ELSE null END FROM source_table; +INSERT INTO target_table SELECT a, CASE WHEN a < 50 THEN b ELSE null END FROM source_table; ERROR: null value in column "b" violates not-null constraint ROLLBACK TO SAVEPOINT s1; SELECT worker_connection_count(:worker_1_port) - :worker_1_connections AS leaked_worker_1_connections, diff --git a/src/test/regress/sql/insert_select_connection_leak.sql b/src/test/regress/sql/insert_select_connection_leak.sql index 167acd9e5..05afb10a0 100644 --- a/src/test/regress/sql/insert_select_connection_leak.sql +++ b/src/test/regress/sql/insert_select_connection_leak.sql @@ -18,7 +18,7 @@ SELECT create_distributed_table('source_table', 'a'); CREATE TABLE target_table(a numeric, b int not null); SELECT create_distributed_table('target_table', 'a'); -INSERT INTO source_table SELECT i, 2 * i FROM generate_series(1, 10000) i; +INSERT INTO source_table SELECT i, 2 * i FROM generate_series(1, 100) i; EXPLAIN (costs off) INSERT INTO target_table SELECT * FROM source_table; @@ -57,7 +57,7 @@ INSERT INTO target_table SELECT * FROM source_table; SELECT worker_connection_count(:worker_1_port) AS worker_1_connections, worker_connection_count(:worker_2_port) AS worker_2_connections \gset SAVEPOINT s1; -INSERT INTO target_table SELECT a, CASE WHEN a < 5000 THEN b ELSE null END FROM source_table; +INSERT INTO target_table SELECT a, CASE WHEN a < 50 THEN b ELSE null END FROM source_table; ROLLBACK TO SAVEPOINT s1; SELECT worker_connection_count(:worker_1_port) - :worker_1_connections AS leaked_worker_1_connections, worker_connection_count(:worker_2_port) - :worker_2_connections AS leaked_worker_2_connections;