diff --git a/src/backend/distributed/commands/table.c b/src/backend/distributed/commands/table.c index ee9636f65..2cca36539 100644 --- a/src/backend/distributed/commands/table.c +++ b/src/backend/distributed/commands/table.c @@ -101,8 +101,8 @@ PreprocessDropTableStmt(Node *node, const char *queryString) Oid relationId = RangeVarGetRelid(tableRangeVar, AccessShareLock, missingOK); - /* we're not interested in non-valid, non-distributed relations */ - if (relationId == InvalidOid || !IsCitusTable(relationId)) + /* we're not interested in non-valid relations */ + if (relationId == InvalidOid) { continue; } @@ -120,6 +120,12 @@ PreprocessDropTableStmt(Node *node, const char *queryString) MarkInvalidateForeignKeyGraph(); } + /* we're not interested in non-distributed relations */ + if (!IsCitusTable(relationId)) + { + continue; + } + /* we're only interested in partitioned and mx tables */ if (!ShouldSyncTableMetadata(relationId) || !PartitionedTable(relationId)) {