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 16:14:58 +01:00
parent 109d15d604
commit 1a1b94aa24
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -178,7 +178,7 @@ BuildGlobalWaitGraph(bool onlyDistributedTx)
if (onlyDistributedTx) if (onlyDistributedTx)
{ {
appendStringInfo(queryString, appendStringInfo(queryString,
"SELECT waiting_pid integer, waiting_node_id integer, " "SELECT waiting_pid, waiting_node_id, "
"waiting_transaction_num, waiting_transaction_stamp, " "waiting_transaction_num, waiting_transaction_stamp, "
"blocking_pid, blocking_node_id, blocking_transaction_num, " "blocking_pid, blocking_node_id, blocking_transaction_num, "
"blocking_transaction_stamp, blocking_transaction_waiting " "blocking_transaction_stamp, blocking_transaction_waiting "
@ -187,11 +187,10 @@ BuildGlobalWaitGraph(bool onlyDistributedTx)
else else
{ {
appendStringInfo(queryString, appendStringInfo(queryString,
"SELECT waiting_global_pid bigint, waiting_pid integer, " "SELECT waiting_global_pid, waiting_pid, "
"waiting_node_id integer, " "waiting_node_id, waiting_transaction_num, waiting_transaction_stamp, "
"waiting_transaction_num, waiting_transaction_stamp, " "blocking_global_pid,blocking_pid, blocking_node_id, "
"blocking_global_pid,blocking_pid, blocking_node_id, blocking_transaction_num, " "blocking_transaction_num, blocking_transaction_stamp, blocking_transaction_waiting "
"blocking_transaction_stamp, blocking_transaction_waiting "
"FROM citus_internal_local_blocked_processes()"); "FROM citus_internal_local_blocked_processes()");
} }