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

Fixing testcase

users/saawasek/non_blocking_split_integrated
Sameer Awasekar 2022-08-03 14:36:44 +05:30
parent dd73cfe843
commit 2988a677c1
4 changed files with 22 additions and 42 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/test/regress/expected/citus_non_blocking_split_shard_cleanup.out
View File

@ -77,18 +77,20 @@ SELECT slot_name FROM pg_replication_slots;
(0 rows) (0 rows)
-- Publications should be cleaned up on worker1 -- Publications should be cleaned up on worker1
SELECT * FROM pg_publication; SELECT count(*) FROM pg_publication;
oid | pubname | pubowner | puballtables | pubinsert | pubupdate | pubdelete | pubtruncate | pubviaroot count
--------------------------------------------------------------------- ---------------------------------------------------------------------
(0 rows) 0
(1 row)
\c - - - :worker_2_port \c - - - :worker_2_port
SET search_path TO "citus_split_test_schema"; SET search_path TO "citus_split_test_schema";
-- All subscriptions should be cleaned up. -- All subscriptions should be cleaned up.
SELECT * FROM pg_subscription; SELECT count(*) FROM pg_subscription;
oid | subdbid | subname | subowner | subenabled | subbinary | substream | subconninfo | subslotname | subsynccommit | subpublications count
--------------------------------------------------------------------- ---------------------------------------------------------------------
(0 rows) 0
(1 row)
-- Trigger a 3-way local split. -- Trigger a 3-way local split.
\c - - - :master_port \c - - - :master_port
@ -112,14 +114,16 @@ SELECT slot_name FROM pg_replication_slots;
(0 rows) (0 rows)
-- Publications should be cleanedup -- Publications should be cleanedup
SELECT * FROM pg_publication; SELECT count(*) FROM pg_publication;
oid | pubname | pubowner | puballtables | pubinsert | pubupdate | pubdelete | pubtruncate | pubviaroot count
--------------------------------------------------------------------- ---------------------------------------------------------------------
(0 rows) 0
(1 row)
-- All subscriptions should be cleaned up. -- All subscriptions should be cleaned up.
SELECT * FROM pg_subscription; SELECT count(*) FROM pg_subscription;
oid | subdbid | subname | subowner | subenabled | subbinary | substream | subconninfo | subslotname | subsynccommit | subpublications count
--------------------------------------------------------------------- ---------------------------------------------------------------------
(0 rows) 0
(1 row)

14
src/test/regress/expected/citus_split_shard_by_split_points_negative.out
View File

@ -32,19 +32,7 @@ SELECT create_distributed_table('table_to_split','id');
SELECT nodeid AS worker_1_node FROM pg_dist_node WHERE nodeport=:worker_1_port \gset SELECT nodeid AS worker_1_node FROM pg_dist_node WHERE nodeport=:worker_1_port \gset
SELECT nodeid AS worker_2_node FROM pg_dist_node WHERE nodeport=:worker_2_port \gset SELECT nodeid AS worker_2_node FROM pg_dist_node WHERE nodeport=:worker_2_port \gset
-- UDF fails for any other shard_transfer_mode other than block_writes. -- UDF fails for any other shard_transfer_mode other than block_writes/force_logical/auto.
SELECT citus_split_shard_by_split_points(
49761302,
ARRAY['50'],
ARRAY[101, 201],
'auto');
ERROR: Shard Tranfer mode: 'auto' is not supported. Please use 'block_writes' instead.
SELECT citus_split_shard_by_split_points(
49761302,
ARRAY['50'],
ARRAY[101, 201],
'force_logical');
ERROR: Shard Tranfer mode: 'force_logical' is not supported. Please use 'block_writes' instead.
SELECT citus_split_shard_by_split_points( SELECT citus_split_shard_by_split_points(
49761302, 49761302,
ARRAY['50'], ARRAY['50'],

8
src/test/regress/sql/citus_non_blocking_split_shard_cleanup.sql
View File

@ -66,12 +66,12 @@ SELECT count(*) FROM pg_class where relname like '%sensors_8981008%';
SELECT slot_name FROM pg_replication_slots; SELECT slot_name FROM pg_replication_slots;
-- Publications should be cleaned up on worker1 -- Publications should be cleaned up on worker1
SELECT * FROM pg_publication; SELECT count(*) FROM pg_publication;
\c - - - :worker_2_port \c - - - :worker_2_port
SET search_path TO "citus_split_test_schema"; SET search_path TO "citus_split_test_schema";
-- All subscriptions should be cleaned up. -- All subscriptions should be cleaned up.
SELECT * FROM pg_subscription; SELECT count(*) FROM pg_subscription;
-- Trigger a 3-way local split. -- Trigger a 3-way local split.
\c - - - :master_port \c - - - :master_port
@ -88,6 +88,6 @@ SET search_path TO "citus_split_test_schema";
SELECT slot_name FROM pg_replication_slots; SELECT slot_name FROM pg_replication_slots;
-- Publications should be cleanedup -- Publications should be cleanedup
SELECT * FROM pg_publication; SELECT count(*) FROM pg_publication;
-- All subscriptions should be cleaned up. -- All subscriptions should be cleaned up.
SELECT * FROM pg_subscription; SELECT count(*) FROM pg_subscription;

14
src/test/regress/sql/citus_split_shard_by_split_points_negative.sql
View File

@ -23,19 +23,7 @@ SELECT create_distributed_table('table_to_split','id');
SELECT nodeid AS worker_1_node FROM pg_dist_node WHERE nodeport=:worker_1_port \gset SELECT nodeid AS worker_1_node FROM pg_dist_node WHERE nodeport=:worker_1_port \gset
SELECT nodeid AS worker_2_node FROM pg_dist_node WHERE nodeport=:worker_2_port \gset SELECT nodeid AS worker_2_node FROM pg_dist_node WHERE nodeport=:worker_2_port \gset
-- UDF fails for any other shard_transfer_mode other than block_writes. -- UDF fails for any other shard_transfer_mode other than block_writes/force_logical/auto.
SELECT citus_split_shard_by_split_points(
49761302,
ARRAY['50'],
ARRAY[101, 201],
'auto');
SELECT citus_split_shard_by_split_points(
49761302,
ARRAY['50'],
ARRAY[101, 201],
'force_logical');
SELECT citus_split_shard_by_split_points( SELECT citus_split_shard_by_split_points(
49761302, 49761302,
ARRAY['50'], ARRAY['50'],