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$$);