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

use remote nodes instead

pull/7483/head
Onur Tirtir 2024-02-22 13:07:50 +03:00
parent 4f4cdff9ee
commit 4c46d4b265
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/backend/distributed/commands/database.c
View File

@ -508,14 +508,18 @@ PreprocessCreateDatabaseStmt(Node *node, const char *queryString,
char *tempDatabaseName = psprintf(TEMP_DATABASE_NAME_FMT, char *tempDatabaseName = psprintf(TEMP_DATABASE_NAME_FMT,
operationId, GetLocalGroupId()); operationId, GetLocalGroupId());
List *allNodes = TargetWorkerSetNodeList(ALL_SHARD_NODES, RowShareLock); /*
WorkerNode *workerNode = NULL; * Temporary database creation on local node would anyway rollback
foreach_ptr(workerNode, allNodes) * in case of a failure, so only insert the records for remote nodes.
*/
List *remoteNodes = TargetWorkerSetNodeList(REMOTE_NODES, RowShareLock);
WorkerNode *remoteNode = NULL;
foreach_ptr(remoteNode, remoteNodes)
{ {
InsertCleanupRecordOutsideTransaction( InsertCleanupRecordOutsideTransaction(
CLEANUP_OBJECT_DATABASE, CLEANUP_OBJECT_DATABASE,
pstrdup(quote_identifier(tempDatabaseName)), pstrdup(quote_identifier(tempDatabaseName)),
workerNode->groupId, remoteNode->groupId,
CLEANUP_ON_FAILURE CLEANUP_ON_FAILURE
); );
} }