Fix multi_colocation test

ref_on_buraks
Burak Velioglu 2022-01-25 16:47:13 +03:00
parent b8e5da0779
commit 233230968f
No known key found for this signature in database
GPG Key ID: F6827E620F6549C6
1 changed files with 3 additions and 5 deletions

View File

@ -410,11 +410,9 @@ SELECT update_distributed_table_colocation('table1_group_none', colocate_with =>
SELECT update_distributed_table_colocation('table1_group_none', colocate_with => 'table2_groupE'); SELECT update_distributed_table_colocation('table1_group_none', colocate_with => 'table2_groupE');
SELECT update_distributed_table_colocation('table1_group_none', colocate_with => 'table3_groupE'); SELECT update_distributed_table_colocation('table1_group_none', colocate_with => 'table3_groupE');
-- sync metadata to get rid of inconsistencies in pg_dist tables -- activate node to get rid of inconsistencies in pg_dist tables
select stop_metadata_sync_to_node('localhost', :worker_1_port); select citus_activate_node('localhost', :worker_1_port);
select stop_metadata_sync_to_node('localhost', :worker_2_port); select citus_activate_node('localhost', :worker_2_port);
select start_metadata_sync_to_node('localhost', :worker_1_port);
select start_metadata_sync_to_node('localhost', :worker_2_port);
-- move a table with a colocation id which is already not in pg_dist_colocation -- move a table with a colocation id which is already not in pg_dist_colocation
SELECT update_distributed_table_colocation('table1_group_none', colocate_with => 'table2_group_none'); SELECT update_distributed_table_colocation('table1_group_none', colocate_with => 'table2_group_none');