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

Fix mx tests

ref_on_buraks
Burak Velioglu 2022-01-25 01:23:42 +03:00
parent 56969c09da
commit 3260bf3513
No known key found for this signature in database
GPG Key ID: F6827E620F6549C6
2 changed files with 25 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/test/regress/expected/multi_mx_add_coordinator.out
View File

@ -49,11 +49,17 @@ SET citus.shard_count TO 8;
SET citus.next_shard_id TO 7000000; SET citus.next_shard_id TO 7000000;
SET citus.next_placement_id TO 7000000; SET citus.next_placement_id TO 7000000;
SET client_min_messages TO WARNING; SET client_min_messages TO WARNING;
-- test that coordinator pg_dist_node entry is synced to the workers -- test that metadata is synced to the workers
SELECT wait_until_metadata_sync(30000); SELECT 1 FROM citus_activate_node('localhost', :worker_1_port);
wait_until_metadata_sync ?column?
--------------------------------------------------------------------- ---------------------------------------------------------------------
1
(1 row)
SELECT 1 FROM citus_activate_node('localhost', :worker_2_port);
?column?
---------------------------------------------------------------------
1
(1 row) (1 row)
SELECT verify_metadata('localhost', :worker_1_port), SELECT verify_metadata('localhost', :worker_1_port),
@ -335,11 +341,17 @@ SELECT master_remove_node('localhost', :master_port);
(1 row) (1 row)
-- test that coordinator pg_dist_node entry was removed from the workers -- test that metadata is synced to the workers
SELECT wait_until_metadata_sync(30000); SELECT 1 FROM citus_activate_node('localhost', :worker_1_port);
wait_until_metadata_sync ?column?
--------------------------------------------------------------------- ---------------------------------------------------------------------
1
(1 row)
SELECT 1 FROM citus_activate_node('localhost', :worker_2_port);
?column?
---------------------------------------------------------------------
1
(1 row) (1 row)
SELECT verify_metadata('localhost', :worker_1_port), SELECT verify_metadata('localhost', :worker_1_port),

11
src/test/regress/sql/multi_mx_add_coordinator.sql
View File

@ -31,8 +31,9 @@ SET citus.next_shard_id TO 7000000;
SET citus.next_placement_id TO 7000000; SET citus.next_placement_id TO 7000000;
SET client_min_messages TO WARNING; SET client_min_messages TO WARNING;
-- test that coordinator pg_dist_node entry is synced to the workers -- test that metadata is synced to the workers
SELECT wait_until_metadata_sync(30000); SELECT 1 FROM citus_activate_node('localhost', :worker_1_port);
SELECT 1 FROM citus_activate_node('localhost', :worker_2_port);
SELECT verify_metadata('localhost', :worker_1_port), SELECT verify_metadata('localhost', :worker_1_port),
verify_metadata('localhost', :worker_2_port); verify_metadata('localhost', :worker_2_port);
@ -174,8 +175,10 @@ SET client_min_messages TO ERROR;
DROP TABLE distributed_table, referece_table, local_fkey_table; DROP TABLE distributed_table, referece_table, local_fkey_table;
SELECT master_remove_node('localhost', :master_port); SELECT master_remove_node('localhost', :master_port);
-- test that coordinator pg_dist_node entry was removed from the workers -- test that metadata is synced to the workers
SELECT wait_until_metadata_sync(30000); SELECT 1 FROM citus_activate_node('localhost', :worker_1_port);
SELECT 1 FROM citus_activate_node('localhost', :worker_2_port);
SELECT verify_metadata('localhost', :worker_1_port), SELECT verify_metadata('localhost', :worker_1_port),
verify_metadata('localhost', :worker_2_port); verify_metadata('localhost', :worker_2_port);