mirror of https://github.com/citusdata/citus.git
Clean up resources in background rebalance test
This test would leave some clean up records around. Which caused issues in the test that Emel tried to add after it.pull/6803/head
parent
37500806d6
commit
f346bab724
|
@ -291,6 +291,12 @@ SELECT state, details from citus_rebalance_status();
|
||||||
finished | {"tasks": [], "task_state_counts": {"done": 2}}
|
finished | {"tasks": [], "task_state_counts": {"done": 2}}
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
|
SELECT public.wait_for_resource_cleanup();
|
||||||
|
wait_for_resource_cleanup
|
||||||
|
---------------------------------------------------------------------
|
||||||
|
|
||||||
|
(1 row)
|
||||||
|
|
||||||
-- Remove coordinator again to allow rerunning of this test
|
-- Remove coordinator again to allow rerunning of this test
|
||||||
SELECT 1 FROM citus_remove_node('localhost', :master_port);
|
SELECT 1 FROM citus_remove_node('localhost', :master_port);
|
||||||
?column?
|
?column?
|
||||||
|
|
|
@ -104,6 +104,8 @@ SELECT 1 FROM citus_rebalance_start(shard_transfer_mode := 'force_logical');
|
||||||
SELECT citus_rebalance_wait();
|
SELECT citus_rebalance_wait();
|
||||||
SELECT state, details from citus_rebalance_status();
|
SELECT state, details from citus_rebalance_status();
|
||||||
|
|
||||||
|
SELECT public.wait_for_resource_cleanup();
|
||||||
|
|
||||||
-- Remove coordinator again to allow rerunning of this test
|
-- Remove coordinator again to allow rerunning of this test
|
||||||
SELECT 1 FROM citus_remove_node('localhost', :master_port);
|
SELECT 1 FROM citus_remove_node('localhost', :master_port);
|
||||||
SELECT public.wait_until_metadata_sync(30000);
|
SELECT public.wait_until_metadata_sync(30000);
|
||||||
|
|
Loading…
Reference in New Issue