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

Merge pull request #5544 from citusdata/turn_metadata_sync_on_in_multi_replicate_reference_table 

Turn metadata sync on in multi_replicate_reference_table and multi_citus_tools
pull/4634/head
Halil Ozan Akgül 2021-12-17 11:04:41 +03:00 committed by GitHub
parent cc4c83b1e5 df8d0f3db1
commit 5b1a25ae7c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 2 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/test/regress/expected/multi_replicate_reference_table.out
View File

@ -669,7 +669,7 @@ ORDER BY shardid, nodeport;
(0 rows) (0 rows)
-- verify constraints have been created on the new node -- verify constraints have been created on the new node
SELECT run_command_on_workers('select count(*) from pg_constraint where contype=''f'' AND conname like ''ref_table%'';'); SELECT run_command_on_workers('select count(*) from pg_constraint where contype=''f'' AND conname similar to ''ref_table%\d'';');
run_command_on_workers run_command_on_workers
--------------------------------------------------------------------- ---------------------------------------------------------------------
(localhost,57637,t,2) (localhost,57637,t,2)
@ -950,12 +950,6 @@ SELECT 1 FROM master_add_node('localhost', :worker_2_port);
(1 row) (1 row)
SET citus.shard_replication_factor TO 1; SET citus.shard_replication_factor TO 1;
SELECT start_metadata_sync_to_node('localhost', :worker_1_port);
start_metadata_sync_to_node
---------------------------------------------------------------------
(1 row)
SELECT master_copy_shard_placement( SELECT master_copy_shard_placement(
:ref_table_shard, :ref_table_shard,
'localhost', :worker_1_port, 'localhost', :worker_1_port,
@ -1027,13 +1021,6 @@ WHERE ref_table.a = dist_table.a;
\c - - - :master_port \c - - - :master_port
SET search_path TO replicate_reference_table; SET search_path TO replicate_reference_table;
SELECT stop_metadata_sync_to_node('localhost', :worker_1_port);
NOTICE: dropping metadata on the node (localhost,57637)
stop_metadata_sync_to_node
---------------------------------------------------------------------
(1 row)
-- --
-- The following case used to get stuck on create_distributed_table() instead -- The following case used to get stuck on create_distributed_table() instead
-- of detecting the distributed deadlock. -- of detecting the distributed deadlock.

3
src/test/regress/multi_1_schedule
View File

@ -48,8 +48,6 @@ test: multi_read_from_secondaries
# ---------- # ----------
# multi_citus_tools tests utility functions written for citus tools # multi_citus_tools tests utility functions written for citus tools
# ---------- # ----------
test: check_mx
test: turn_mx_off
test: multi_citus_tools test: multi_citus_tools
# ---------- # ----------
@ -57,7 +55,6 @@ test: multi_citus_tools
# multi_remove_node_reference_table tests metadata changes after master_remove_node # multi_remove_node_reference_table tests metadata changes after master_remove_node
# ---------- # ----------
test: multi_replicate_reference_table test: multi_replicate_reference_table
test: turn_mx_on
test: multi_remove_node_reference_table test: multi_remove_node_reference_table
# ---------- # ----------

5
src/test/regress/sql/multi_replicate_reference_table.sql
View File

@ -451,7 +451,7 @@ WHERE
ORDER BY shardid, nodeport; ORDER BY shardid, nodeport;
-- verify constraints have been created on the new node -- verify constraints have been created on the new node
SELECT run_command_on_workers('select count(*) from pg_constraint where contype=''f'' AND conname like ''ref_table%'';'); SELECT run_command_on_workers('select count(*) from pg_constraint where contype=''f'' AND conname similar to ''ref_table%\d'';');
DROP TABLE ref_table_1, ref_table_2, ref_table_3; DROP TABLE ref_table_1, ref_table_2, ref_table_3;
@ -591,7 +591,6 @@ SELECT 1 FROM master_remove_node('localhost', :worker_2_port);
SELECT 1 FROM master_add_node('localhost', :worker_2_port); SELECT 1 FROM master_add_node('localhost', :worker_2_port);
SET citus.shard_replication_factor TO 1; SET citus.shard_replication_factor TO 1;
SELECT start_metadata_sync_to_node('localhost', :worker_1_port);
SELECT master_copy_shard_placement( SELECT master_copy_shard_placement(
:ref_table_shard, :ref_table_shard,
@ -637,8 +636,6 @@ WHERE ref_table.a = dist_table.a;
SET search_path TO replicate_reference_table; SET search_path TO replicate_reference_table;
SELECT stop_metadata_sync_to_node('localhost', :worker_1_port);
-- --
-- The following case used to get stuck on create_distributed_table() instead -- The following case used to get stuck on create_distributed_table() instead
-- of detecting the distributed deadlock. -- of detecting the distributed deadlock.