From 114f6249365f78a2fb177a9cf22f90d9803c5a39 Mon Sep 17 00:00:00 2001 From: naisila Date: Mon, 13 Nov 2023 10:59:22 +0300 Subject: [PATCH] Test whether flaky citus_split_shard_by_split_points --- .../citus_split_shard_by_split_points.out | 31 ++++++++++++++++--- .../sql/citus_split_shard_by_split_points.sql | 6 ++++ 2 files changed, 32 insertions(+), 5 deletions(-) diff --git a/src/test/regress/expected/citus_split_shard_by_split_points.out b/src/test/regress/expected/citus_split_shard_by_split_points.out index 13f3b7a36..0f90504d3 100644 --- a/src/test/regress/expected/citus_split_shard_by_split_points.out +++ b/src/test/regress/expected/citus_split_shard_by_split_points.out @@ -501,11 +501,32 @@ SELECT pg_reload_conf(); t (1 row) +SET client_min_messages TO error; DROP SCHEMA "citus_split_test_schema" CASCADE; -NOTICE: drop cascades to 4 other objects -DETAIL: drop cascades to table citus_split_test_schema.sensors -drop cascades to table citus_split_test_schema.reference_table -drop cascades to table citus_split_test_schema.colocated_dist_table -drop cascades to table citus_split_test_schema.table_with_index_rep_identity +RESET client_min_messages; DROP USER test_split_role; --END : Cleanup +SELECT result FROM run_command_on_all_nodes($$SELECT count(*) FROM pg_replication_slots$$); + result +--------------------------------------------------------------------- + 0 + 0 + 0 +(3 rows) + +SELECT result FROM run_command_on_all_nodes($$SELECT count(*) FROM pg_publication$$); + result +--------------------------------------------------------------------- + 0 + 0 + 0 +(3 rows) + +SELECT result FROM run_command_on_all_nodes($$SELECT count(*) FROM pg_subscription$$); + result +--------------------------------------------------------------------- + 0 + 0 + 0 +(3 rows) + diff --git a/src/test/regress/sql/citus_split_shard_by_split_points.sql b/src/test/regress/sql/citus_split_shard_by_split_points.sql index 47b28b9d7..d6b750fcd 100644 --- a/src/test/regress/sql/citus_split_shard_by_split_points.sql +++ b/src/test/regress/sql/citus_split_shard_by_split_points.sql @@ -257,6 +257,12 @@ SELECT COUNT(*) FROM colocated_dist_table; \c - postgres - :master_port ALTER SYSTEM RESET citus.defer_shard_delete_interval; SELECT pg_reload_conf(); +SET client_min_messages TO error; DROP SCHEMA "citus_split_test_schema" CASCADE; +RESET client_min_messages; DROP USER test_split_role; --END : Cleanup + +SELECT result FROM run_command_on_all_nodes($$SELECT count(*) FROM pg_replication_slots$$); +SELECT result FROM run_command_on_all_nodes($$SELECT count(*) FROM pg_publication$$); +SELECT result FROM run_command_on_all_nodes($$SELECT count(*) FROM pg_subscription$$);