diff --git a/src/backend/distributed/metadata/metadata_sync.c b/src/backend/distributed/metadata/metadata_sync.c index 005ab3da0..4ebd1beea 100644 --- a/src/backend/distributed/metadata/metadata_sync.c +++ b/src/backend/distributed/metadata/metadata_sync.c @@ -165,9 +165,6 @@ StartMetadataSyncToNode(const char *nodeNameString, int32 nodePort) { char *escapedNodeName = quote_literal_cstr(nodeNameString); - /* fail if metadata synchronization doesn't succeed */ - bool raiseInterrupts = true; - CheckCitusVersion(ERROR); EnsureCoordinator(); EnsureSuperUser(); @@ -217,8 +214,9 @@ StartMetadataSyncToNode(const char *nodeNameString, int32 nodePort) MarkNodeHasMetadata(nodeNameString, nodePort, true); MarkNodeMetadataSynced(workerNode->workerName, workerNode->workerPort, true); + /* fail if metadata synchronization doesn't succeed */ + bool raiseInterrupts = true; SyncMetadataSnapshotToNode(workerNode, raiseInterrupts); - } diff --git a/src/backend/distributed/transaction/worker_transaction.c b/src/backend/distributed/transaction/worker_transaction.c index f2a44bbba..3afa2eaaa 100644 --- a/src/backend/distributed/transaction/worker_transaction.c +++ b/src/backend/distributed/transaction/worker_transaction.c @@ -137,7 +137,7 @@ SendOptionalCommandToWorkersWithMetadata(const char *command) { bool raiseInterrupts = false; return SendCommandToMetadataWorkersParams(command, CurrentUserName(), - 0, NULL, NULL, raiseInterrupts); + 0, NULL, NULL, raiseInterrupts); } @@ -231,9 +231,10 @@ SendCommandToMetadataWorkersParams(const char *command, ErrorIfAnyMetadataNodeOutOfSync(workerNodeList); - return SendCommandToWorkersParamsInternal(NON_COORDINATOR_METADATA_NODES, command, user, - parameterCount, parameterTypes, - parameterValues, raiseInterrupts); + return SendCommandToWorkersParamsInternal(NON_COORDINATOR_METADATA_NODES, command, + user, + parameterCount, parameterTypes, + parameterValues, raiseInterrupts); }