external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

follow feedback

add_worker_query_again
Onder Kalaci 2022-02-15 15:39:47 +01:00
parent 1684154245
commit 109d15d604
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/backend/distributed/transaction/lock_graph.c
View File

@ -178,12 +178,21 @@ BuildGlobalWaitGraph(bool onlyDistributedTx)
if (onlyDistributedTx) if (onlyDistributedTx)
{ {
appendStringInfo(queryString, 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 else
{ {
appendStringInfo(queryString, 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); int querySent = SendRemoteCommand(connection, queryString->data);