wip

src/backend/distributed/cimv/create.c

@@ -719,6 +719,7 @@ CreateRefreshView(CimvCreate *cimvCreate)
 	query->targetList = (List *) PartializeAggs((Node *) query->targetList, &inverse);
 	AddCountAgg(query, true);
 
+	/* TODO:: we probably don't need this part until parse_analyze */
 	StringInfoData querybuf;
 	initStringInfo(&querybuf);
 

src/backend/distributed/commands/utility_hook.c

@@ -461,6 +461,9 @@ multi_ProcessUtility(PlannedStmt *pstmt,
 	bool continueProcessing = true;
 	if (IsA(parsetree, CreateTableAsStmt))
 	{
+		StringInfo buf = makeStringInfo();
+		pg_get_query_def(parsetree, buf);
+		elog(WARNING, "%s", buf->data);
 		continueProcessing = !ProcessCreateMaterializedViewStmt((const
 																 CreateTableAsStmt *)
 																parsetree, queryString,