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

wip

do_not_have_single_tx_command
Onder Kalaci 2021-07-27 18:21:52 +02:00
parent 8698ca8cdc
commit 1cdd8ac512
2 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/backend/distributed/metadata/metadata_sync.c
View File

@ -165,9 +165,6 @@ StartMetadataSyncToNode(const char *nodeNameString, int32 nodePort)
{ {
char *escapedNodeName = quote_literal_cstr(nodeNameString); char *escapedNodeName = quote_literal_cstr(nodeNameString);
/* fail if metadata synchronization doesn't succeed */
bool raiseInterrupts = true;
CheckCitusVersion(ERROR); CheckCitusVersion(ERROR);
EnsureCoordinator(); EnsureCoordinator();
EnsureSuperUser(); EnsureSuperUser();
@ -217,8 +214,9 @@ StartMetadataSyncToNode(const char *nodeNameString, int32 nodePort)
MarkNodeHasMetadata(nodeNameString, nodePort, true); MarkNodeHasMetadata(nodeNameString, nodePort, true);
MarkNodeMetadataSynced(workerNode->workerName, workerNode->workerPort, true); MarkNodeMetadataSynced(workerNode->workerName, workerNode->workerPort, true);
/* fail if metadata synchronization doesn't succeed */
bool raiseInterrupts = true;
SyncMetadataSnapshotToNode(workerNode, raiseInterrupts); SyncMetadataSnapshotToNode(workerNode, raiseInterrupts);
} }

9
src/backend/distributed/transaction/worker_transaction.c
View File

@ -137,7 +137,7 @@ SendOptionalCommandToWorkersWithMetadata(const char *command)
{ {
bool raiseInterrupts = false; bool raiseInterrupts = false;
return SendCommandToMetadataWorkersParams(command, CurrentUserName(), return SendCommandToMetadataWorkersParams(command, CurrentUserName(),
0, NULL, NULL, raiseInterrupts); 0, NULL, NULL, raiseInterrupts);
} }
@ -231,9 +231,10 @@ SendCommandToMetadataWorkersParams(const char *command,
ErrorIfAnyMetadataNodeOutOfSync(workerNodeList); ErrorIfAnyMetadataNodeOutOfSync(workerNodeList);
return SendCommandToWorkersParamsInternal(NON_COORDINATOR_METADATA_NODES, command, user, return SendCommandToWorkersParamsInternal(NON_COORDINATOR_METADATA_NODES, command,
parameterCount, parameterTypes, user,
parameterValues, raiseInterrupts); parameterCount, parameterTypes,
parameterValues, raiseInterrupts);
} }