premature views on mx

src/backend/distributed/commands/alter_table.c

@@ -188,7 +188,6 @@ static void EnsureTableNotPartition(Oid relationId);
 static TableConversionState * CreateTableConversion(TableConversionParameters *params);
 static void CreateDistributedTableLike(TableConversionState *con);
 static void CreateCitusTableLike(TableConversionState *con);
-static List * GetViewCreationCommandsOfTable(Oid relationId);
 static void ReplaceTable(Oid sourceId, Oid targetId, List *justBeforeDropCommands,
 						 bool suppressNoticeMessages);
 static bool HasAnyGeneratedStoredColumns(Oid relationId);

src/backend/distributed/metadata/metadata_sync.c

@@ -481,6 +481,21 @@ MetadataCreateCommands(void)
 												  shardCreateCommandList);
 	}
 
+	/* after all tables are created, create the metadata */
+	foreach_ptr(cacheEntry, propagatedTableList)
+	{
+		Oid relationId = cacheEntry->relationId;
+
+		List *viewDefinitionList = GetViewCreationCommandsOfTable(relationId);
+
+		TableDDLCommand *command = NULL;
+		foreach_ptr(command,viewDefinitionList)
+		{
+		metadataSnapshotCommandList = lappend(metadataSnapshotCommandList,
+				command->commandStr);
+		}
+	}
+
 	return metadataSnapshotCommandList;
 }
 

src/include/distributed/metadata_utility.h

@@ -248,7 +248,7 @@ extern void CreateDistributedTable(Oid relationId, Var *distributionColumn,
 								   bool viaDeprecatedAPI);
 extern void CreateTruncateTrigger(Oid relationId);
 extern TableConversionReturn * UndistributeTable(TableConversionParameters *params);
-
+extern List * GetViewCreationCommandsOfTable(Oid relationId);
 extern void EnsureDependenciesExistOnAllNodes(const ObjectAddress *target);
 extern List * GetDistributableDependenciesForObject(const ObjectAddress *target);
 extern bool ShouldPropagate(void);