diff --git a/src/backend/distributed/transaction/backend_data.c b/src/backend/distributed/transaction/backend_data.c index 5713412d7..5f7980c1d 100644 --- a/src/backend/distributed/transaction/backend_data.c +++ b/src/backend/distributed/transaction/backend_data.c @@ -406,8 +406,16 @@ StoreAllActiveTransactions(Tuplestorestate *tupleStore, TupleDesc tupleDescripto continue; } + PGPROC *currentProc = &ProcGlobal->allProcs[backendIndex]; + if (currentProc->lockGroupLeader != NULL) + { + /* we skip Postgres' parallel workers as it is enough to show the leader */ + SpinLockRelease(¤tBackend->mutex); + continue; + } + Oid databaseId = currentBackend->databaseId; - int backendPid = ProcGlobal->allProcs[backendIndex].pid; + int backendPid = currentProc->pid; initiatorNodeIdentifier = currentBackend->citusBackend.initiatorNodeIdentifier; /*