diff --git a/src/backend/distributed/metadata/node_metadata.c b/src/backend/distributed/metadata/node_metadata.c index 9b98ba010..f20babb73 100644 --- a/src/backend/distributed/metadata/node_metadata.c +++ b/src/backend/distributed/metadata/node_metadata.c @@ -1187,6 +1187,12 @@ ActivateNodeList(List *nodeList) bool syncMetadata = EnableMetadataSync && NodeIsPrimary(workerNode); if (syncMetadata) { + /* + * Update local group id first, as object dependency logic requires to have + * updated local group id. + */ + UpdateLocalGroupIdOnNode(workerNode); + /* * We are going to sync the metadata anyway in this transaction, so do * not fail just because the current metadata is not synced. @@ -1194,12 +1200,6 @@ ActivateNodeList(List *nodeList) SetWorkerColumn(workerNode, Anum_pg_dist_node_metadatasynced, BoolGetDatum(true)); - /* - * Update local group id first, as object dependency logic requires to have - * updated local group id. - */ - UpdateLocalGroupIdOnNode(workerNode); - nodeToSyncMetadata = lappend(nodeToSyncMetadata, workerNode); } }