Address feedback

add_worker_query_again
Onder Kalaci 2022-02-11 17:23:28 +01:00
parent d77bf1e1ae
commit 4fe4fa1562
3 changed files with 7 additions and 5 deletions

View File

@ -101,14 +101,14 @@ step s2-view-worker:
FROM citus_worker_stat_activity
WHERE query NOT ILIKE '%pg_prepared_xacts%' AND
query NOT ILIKE '%COMMIT%' AND
query NOT ILIKE '%dump_local_wait_edges%'
query NOT ILIKE '%dump_local_%'
ORDER BY query, query_hostport DESC;
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_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_1500777 ref_table SET a = (a OPERATOR(pg_catalog.+) 1)|localhost | 57637|coordinator_host | 57636|idle in transaction|Client |ClientRead|postgres|regression
(2 rows)
(6 rows)
step s2-end:
END;

View File

@ -127,8 +127,10 @@ ORDER BY 1;
function create_time_partitions(regclass,interval,timestamp with time zone,timestamp with time zone)
function distributed_tables_colocated(regclass,regclass)
function drop_old_time_partitions(regclass,timestamp with time zone)
function dump_global_wait_edges(boolean)
function dump_local_wait_edges(boolean)
function dump_global_blocked_processes()
function dump_global_wait_edges()
function dump_local_blocked_processes()
function dump_local_wait_edges()
function fetch_intermediate_results(text[],text,integer)
function fix_all_partition_shard_index_names()
function fix_partition_shard_index_names(regclass)

View File

@ -93,7 +93,7 @@ step "s2-view-worker"
FROM citus_worker_stat_activity
WHERE query NOT ILIKE '%pg_prepared_xacts%' AND
query NOT ILIKE '%COMMIT%' AND
query NOT ILIKE '%dump_local_wait_edges%'
query NOT ILIKE '%dump_local_%' AND
ORDER BY query, query_hostport DESC;
}