From 109d15d6048a2084a4980fc7457d46c52815d18e Mon Sep 17 00:00:00 2001 From: Onder Kalaci Date: Tue, 15 Feb 2022 15:39:47 +0100 Subject: [PATCH] follow feedback --- src/backend/distributed/transaction/lock_graph.c | 13 +++++++++++-- 1 file changed, 11 insertions(+), 2 deletions(-) diff --git a/src/backend/distributed/transaction/lock_graph.c b/src/backend/distributed/transaction/lock_graph.c index 92ef7c164..6a98f7571 100644 --- a/src/backend/distributed/transaction/lock_graph.c +++ b/src/backend/distributed/transaction/lock_graph.c @@ -178,12 +178,21 @@ BuildGlobalWaitGraph(bool onlyDistributedTx) if (onlyDistributedTx) { appendStringInfo(queryString, - "SELECT * FROM dump_local_wait_edges()"); + "SELECT waiting_pid integer, waiting_node_id integer, " + "waiting_transaction_num, waiting_transaction_stamp, " + "blocking_pid, blocking_node_id, blocking_transaction_num, " + "blocking_transaction_stamp, blocking_transaction_waiting " + "FROM dump_local_wait_edges()"); } else { appendStringInfo(queryString, - "SELECT * FROM citus_internal_local_blocked_processes()"); + "SELECT waiting_global_pid bigint, waiting_pid integer, " + "waiting_node_id integer, " + "waiting_transaction_num, waiting_transaction_stamp, " + "blocking_global_pid,blocking_pid, blocking_node_id, blocking_transaction_num, " + "blocking_transaction_stamp, blocking_transaction_waiting " + "FROM citus_internal_local_blocked_processes()"); } int querySent = SendRemoteCommand(connection, queryString->data);