From 58b2cff86ff59b3370e4750bc9735dc7142c73ce Mon Sep 17 00:00:00 2001 From: naisila Date: Mon, 13 Nov 2023 11:01:52 +0300 Subject: [PATCH] Test whether flaky citus_split_shard_by_split_points_failure --- ...us_split_shard_by_split_points_failure.out | 24 +++++++++++++++++++ ...us_split_shard_by_split_points_failure.sql | 4 ++++ 2 files changed, 28 insertions(+) diff --git a/src/test/regress/expected/citus_split_shard_by_split_points_failure.out b/src/test/regress/expected/citus_split_shard_by_split_points_failure.out index 4914a9361..a4692cf53 100644 --- a/src/test/regress/expected/citus_split_shard_by_split_points_failure.out +++ b/src/test/regress/expected/citus_split_shard_by_split_points_failure.out @@ -108,3 +108,27 @@ NOTICE: drop cascades to 2 other objects DETAIL: drop cascades to table citus_split_failure_test_schema.sensors drop cascades to table citus_split_failure_test_schema.sensors_colocated --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_failure.sql b/src/test/regress/sql/citus_split_shard_by_split_points_failure.sql index 30fe58083..ea4b0ee49 100644 --- a/src/test/regress/sql/citus_split_shard_by_split_points_failure.sql +++ b/src/test/regress/sql/citus_split_shard_by_split_points_failure.sql @@ -80,3 +80,7 @@ SELECT tbl.relname \c - postgres - :master_port DROP SCHEMA "citus_split_failure_test_schema" CASCADE; --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$$);