From 2907a1f93c36cdea1ea55473b06ffb6f45d06bc7 Mon Sep 17 00:00:00 2001
From: Onder Kalaci <onderkalaci@gmail.com>
Date: Tue, 29 Nov 2022 11:44:18 +0100
Subject: [PATCH] WIP

---
 src/backend/distributed/commands/table.c        | 7 ++-----
 src/backend/distributed/commands/utility_hook.c | 7 +++++++
 2 files changed, 9 insertions(+), 5 deletions(-)

diff --git a/src/backend/distributed/commands/table.c b/src/backend/distributed/commands/table.c
index e097957a0..852374614 100644
--- a/src/backend/distributed/commands/table.c
+++ b/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)
diff --git a/src/backend/distributed/commands/utility_hook.c b/src/backend/distributed/commands/utility_hook.c
index 4aba31468..a080a2547 100644
--- a/src/backend/distributed/commands/utility_hook.c
+++ b/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);