external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Test whether flaky citus_split_shard_by_split_points

pull/7338/head
naisila 2023-11-13 10:59:22 +03:00
parent 4995e99975
commit 114f624936
No known key found for this signature in database
GPG Key ID: A824BA9862D73E6D
2 changed files with 32 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
src/test/regress/expected/citus_split_shard_by_split_points.out
View File

@ -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)

6
src/test/regress/sql/citus_split_shard_by_split_points.sql
View File

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