add_worker_query_again
Onder Kalaci 2022-02-10 10:50:53 +01:00
parent 2c7040486f
commit d5bf975f31
2 changed files with 6 additions and 5 deletions

View File

@ -96,7 +96,7 @@ step s1-commit:
COMMIT; COMMIT;
step s2-stop-connection: step s2-stop-connection:
SELECT stop_session_level_connection_to_node(); SELECT stop_session_level_connection_to_node();
stop_session_level_connection_to_node stop_session_level_connection_to_node
--------------------------------------------------------------------- ---------------------------------------------------------------------
@ -148,7 +148,8 @@ step s1-move-placement-back:
SET client_min_messages to NOTICE; SET client_min_messages to NOTICE;
SHOW log_error_verbosity; SHOW log_error_verbosity;
SELECT master_move_shard_placement((SELECT * FROM selected_shard), 'localhost', 57638, 'localhost', 57637); SELECT master_move_shard_placement((SELECT * FROM selected_shard), 'localhost', 57638, 'localhost', 57637);
<waiting ...>
step s1-move-placement-back: <... completed>
log_error_verbosity log_error_verbosity
--------------------------------------------------------------------- ---------------------------------------------------------------------
verbose verbose
@ -159,7 +160,7 @@ step s1-commit:
COMMIT; COMMIT;
step s2-stop-connection: step s2-stop-connection:
SELECT stop_session_level_connection_to_node(); SELECT stop_session_level_connection_to_node();
stop_session_level_connection_to_node stop_session_level_connection_to_node
--------------------------------------------------------------------- ---------------------------------------------------------------------

View File

@ -106,8 +106,8 @@ step s2-view-worker:
query |query_hostname|query_hostport|distributed_query_host_name|distributed_query_host_port|state |wait_event_type|wait_event|usename |datname query |query_hostname|query_hostport|distributed_query_host_name|distributed_query_host_port|state |wait_event_type|wait_event|usename |datname
--------------------------------------------------------------------- ---------------------------------------------------------------------
UPDATE public.ref_table_1500767 ref_table SET a = (a OPERATOR(pg_catalog.+) 1)|localhost | 57638|coordinator_host | 57636|idle in transaction|Client |ClientRead|postgres|regression UPDATE public.ref_table_1500777 ref_table SET a = (a OPERATOR(pg_catalog.+) 1)|localhost | 57638|coordinator_host | 57636|idle in transaction|Client |ClientRead|postgres|regression
UPDATE public.ref_table_1500767 ref_table SET a = (a OPERATOR(pg_catalog.+) 1)|localhost | 57637|coordinator_host | 57636|idle in transaction|Client |ClientRead|postgres|regression UPDATE public.ref_table_1500777 ref_table SET a = (a OPERATOR(pg_catalog.+) 1)|localhost | 57637|coordinator_host | 57636|idle in transaction|Client |ClientRead|postgres|regression
(2 rows) (2 rows)
step s2-end: step s2-end: