diff --git a/src/backend/distributed/commands/extension.c b/src/backend/distributed/commands/extension.c index 7525a394f..7ea8604fa 100644 --- a/src/backend/distributed/commands/extension.c +++ b/src/backend/distributed/commands/extension.c @@ -523,17 +523,22 @@ MarkExistingObjectDependenciesDistributedIfSupported() resultingObjectAddresses = lappend(resultingObjectAddresses, addressPointer); List *viewList = GetDependingViews(citusTableId); + elog(WARNING, "size: %d", list_length(viewList)); + + Oid viewOid = InvalidOid; foreach_oid(viewOid, viewList) { ObjectAddress viewAddress = { 0 }; ObjectAddressSet(viewAddress, RelationRelationId, viewOid); - - if (DeferErrorIfHasUnsupportedDependency(&viewAddress) == NULL) + DeferredErrorMessage *msg = DeferErrorIfHasUnsupportedDependency(&viewAddress); + if (msg == NULL) { /* as of Citus 11, tables that should be synced are also considered object */ resultingObjectAddresses = lappend(resultingObjectAddresses, addressPointer); } + else + RaiseDeferredErrorInternal(msg, WARNING); } }