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

Merge branch 'main' into check-for-citus-table-in-worker_copy_table_to_node

pull/7662/head
Onur Tirtir 2025-03-05 17:17:46 +03:00 committed by GitHub
parent 8569634501 afcda3feff
commit ab85703e0e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/backend/distributed/clock/causal_clock.c
View File

@ -431,6 +431,11 @@ PrepareAndSetTransactionClock(void)
MultiConnection *connection = dlist_container(MultiConnection, transactionNode, MultiConnection *connection = dlist_container(MultiConnection, transactionNode,
iter.cur); iter.cur);
WorkerNode *workerNode = FindWorkerNode(connection->hostname, connection->port); WorkerNode *workerNode = FindWorkerNode(connection->hostname, connection->port);
if (!workerNode)
{
ereport(WARNING, errmsg("Worker node is missing"));
continue;
}
/* Skip the node if we already in the list */ /* Skip the node if we already in the list */
if (list_member_int(nodeList, workerNode->groupId)) if (list_member_int(nodeList, workerNode->groupId))