WIP

src/backend/distributed/commands/table.c

@@ -219,14 +219,11 @@ PreprocessDropTableStmt(Node *node, const char *queryString,
  * table is a distributed table, this function errors out, as we currently don't
  * support local tables inheriting a distributed table.
  */
-#include "utils/inval.h"
+
 void
 PostprocessCreateTableStmt(CreateStmt *createStatement, const char *queryString)
 {
-	if (!IsCoordinator())
-	{
-		CacheInvalidateRelcacheAll();
-	}
+
 	PostprocessCreateTableStmtForeignKeys(createStatement);
 
 	if (createStatement->inhRelations != NIL)

src/backend/distributed/commands/utility_hook.c

@@ -721,6 +721,13 @@ ProcessUtilityInternal(PlannedStmt *pstmt,
 			PreprocessAlterExtensionCitusStmtForCitusColumnar(parsetree);
 		}
 
+#include "utils/inval.h"
+		if (IsA(parsetree, CreateStmt) && !IsCoordinator())
+
+		{
+			CacheInvalidateRelcacheAll();
+		}
+
 		PrevProcessUtility_compat(pstmt, queryString, false, context,
 								  params, queryEnv, dest, completionTag);