From 7d57c7e1f9c0e024e0d006e7532763b3cf8a5fc4 Mon Sep 17 00:00:00 2001 From: Onder Kalaci Date: Mon, 25 Apr 2022 17:10:39 +0200 Subject: [PATCH] upgrade test --- src/backend/distributed/commands/extension.c | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) 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); } }