Adds IsAnyObjectDistributed check for db

pull/7240/head
gindibay 2023-11-13 13:44:08 +03:00
parent 8728871cc3
commit 52c9e92544
1 changed files with 4 additions and 1 deletions

View File

@ -386,7 +386,10 @@ UnmarkNodeWideObjectsDistributed(Node *node)
Oid dbOid = get_database_oid(dbName, stmt->missing_ok);
ObjectAddress *dbObjectAddress = palloc0(sizeof(ObjectAddress));
ObjectAddressSet(*dbObjectAddress, DatabaseRelationId, dbOid);
UnmarkObjectDistributed(dbObjectAddress);
if(IsAnyObjectDistributed(list_make1(dbObjectAddress)))
{
UnmarkObjectDistributed(dbObjectAddress);
}
}
}