external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Revert "upgrade test" 

This reverts commit 7d57c7e1f9.
onder_view_2
Onder Kalaci 2022-04-25 17:14:04 +02:00
parent 7d57c7e1f9
commit 15541d1c45
1 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/backend/distributed/commands/extension.c
View File

@ -523,22 +523,17 @@ MarkExistingObjectDependenciesDistributedIfSupported()
resultingObjectAddresses = lappend(resultingObjectAddresses, addressPointer); resultingObjectAddresses = lappend(resultingObjectAddresses, addressPointer);
List *viewList = GetDependingViews(citusTableId); List *viewList = GetDependingViews(citusTableId);
elog(WARNING, "size: %d", list_length(viewList));
Oid viewOid = InvalidOid; Oid viewOid = InvalidOid;
foreach_oid(viewOid, viewList) foreach_oid(viewOid, viewList)
{ {
ObjectAddress viewAddress = { 0 }; ObjectAddress viewAddress = { 0 };
ObjectAddressSet(viewAddress, RelationRelationId, viewOid); ObjectAddressSet(viewAddress, RelationRelationId, viewOid);
DeferredErrorMessage *msg = DeferErrorIfHasUnsupportedDependency(&viewAddress);
if (msg == NULL) if (DeferErrorIfHasUnsupportedDependency(&viewAddress) == NULL)
{ {
/* as of Citus 11, tables that should be synced are also considered object */ /* as of Citus 11, tables that should be synced are also considered object */
resultingObjectAddresses = lappend(resultingObjectAddresses, addressPointer); resultingObjectAddresses = lappend(resultingObjectAddresses, addressPointer);
} }
else
RaiseDeferredErrorInternal(msg, WARNING);
} }
} }