diff --git a/src/backend/distributed/commands/database.c b/src/backend/distributed/commands/database.c
index 1be537815..75a6cc501 100644
--- a/src/backend/distributed/commands/database.c
+++ b/src/backend/distributed/commands/database.c
@@ -179,6 +179,8 @@ PreprocessAlterDatabaseStmt(Node *node, const char *queryString,
 }
 
 
+#if PG_VERSION_NUM >= PG_VERSION_15
+
 /*
  * PreprocessAlterDatabaseSetStmt is executed before the statement is applied to the local
  * postgres instance.
@@ -207,3 +209,4 @@ PreprocessAlterDatabaseRefreshCollStmt(Node *node, const char *queryString,
 
 	return NodeDDLTaskList(NON_COORDINATOR_NODES, commands);
 }
+#endif
diff --git a/src/backend/distributed/commands/distribute_object_ops.c b/src/backend/distributed/commands/distribute_object_ops.c
index 1b55c1fc7..cd6944a4e 100644
--- a/src/backend/distributed/commands/distribute_object_ops.c
+++ b/src/backend/distributed/commands/distribute_object_ops.c
@@ -455,7 +455,7 @@ static DistributeObjectOps Database_Alter = {
 	.markDistributed = false,
 };
 
-
+#if PG_VERSION_NUM >= PG_VERSION_15
 static DistributeObjectOps Database_RefreshColl = {
 	.deparse = DeparseAlterDatabaseRefreshCollStmt,
 	.qualify = NULL,
@@ -466,6 +466,7 @@ static DistributeObjectOps Database_RefreshColl = {
 	.address = NULL,
 	.markDistributed = false,
 };
+#endif
 
 static DistributeObjectOps Domain_Alter = {
 	.deparse = DeparseAlterDomainStmt,
@@ -1309,12 +1310,12 @@ GetDistributeObjectOps(Node *node)
 		{
 			return &Database_Alter;
 		}
-
+#if PG_VERSION_NUM >= PG_VERSION_15
 		case T_AlterDatabaseRefreshCollStmt:
 		{
 			return &Database_RefreshColl;
 		}
-
+#endif
 		case T_AlterDomainStmt:
 		{
 			return &Domain_Alter;