From 8698ca8cdcbbe93d5b7f6adb151be6fc9a11756e Mon Sep 17 00:00:00 2001 From: Onder Kalaci Date: Tue, 27 Jul 2021 17:58:17 +0200 Subject: [PATCH] wip --- src/backend/distributed/metadata/metadata_sync.c | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/backend/distributed/metadata/metadata_sync.c b/src/backend/distributed/metadata/metadata_sync.c index 18795dc4f..005ab3da0 100644 --- a/src/backend/distributed/metadata/metadata_sync.c +++ b/src/backend/distributed/metadata/metadata_sync.c @@ -204,6 +204,7 @@ StartMetadataSyncToNode(const char *nodeNameString, int32 nodePort) } UseCoordinatedTransaction(); + if (!NodeIsPrimary(workerNode)) { /* @@ -213,9 +214,11 @@ StartMetadataSyncToNode(const char *nodeNameString, int32 nodePort) return; } - SyncMetadataSnapshotToNode(workerNode, raiseInterrupts); MarkNodeHasMetadata(nodeNameString, nodePort, true); MarkNodeMetadataSynced(workerNode->workerName, workerNode->workerPort, true); + + SyncMetadataSnapshotToNode(workerNode, raiseInterrupts); + }