diff --git a/src/backend/distributed/cimv/create.c b/src/backend/distributed/cimv/create.c
index 7f5f3acd6..73fd21f93 100644
--- a/src/backend/distributed/cimv/create.c
+++ b/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);
 
diff --git a/src/backend/distributed/commands/utility_hook.c b/src/backend/distributed/commands/utility_hook.c
index 5dd58407e..41643c4ef 100644
--- a/src/backend/distributed/commands/utility_hook.c
+++ b/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,