diff --git a/src/backend/distributed/commands/statistics.c b/src/backend/distributed/commands/statistics.c
index 371b6c098..ababdd1a8 100644
--- a/src/backend/distributed/commands/statistics.c
+++ b/src/backend/distributed/commands/statistics.c
@@ -442,8 +442,8 @@ GetExplicitStatisticsCommandList(Oid relationId)
 	foreach_oid(statisticsId, statisticsIdList)
 	{
 		/* we need create commands for already created stats before distribution */
-		char *createStatisticsCommand = pg_get_statisticsobj_worker(statisticsId,
-																	false, false);
+		char *createStatisticsCommand = pg_get_statisticsobj_worker_compat(statisticsId,
+																		   false, false);
 
 		explicitStatisticsCommandList =
 			lappend(explicitStatisticsCommandList,
diff --git a/src/include/distributed/citus_ruleutils.h b/src/include/distributed/citus_ruleutils.h
index 2bb008c5e..fac19352d 100644
--- a/src/include/distributed/citus_ruleutils.h
+++ b/src/include/distributed/citus_ruleutils.h
@@ -50,8 +50,12 @@ char * pg_get_rule_expr(Node *expression);
 extern void deparse_shard_query(Query *query, Oid distrelid, int64 shardid,
 								StringInfo buffer);
 extern char * pg_get_triggerdef_command(Oid triggerId);
+#if PG_VERSION_NUM >= PG_VERSION_14
 extern char * pg_get_statisticsobj_worker(Oid statextid, bool columns_only,
 										  bool missing_ok);
+#else
+extern char * pg_get_statisticsobj_worker(Oid statextid, bool missing_ok);
+#endif
 extern char * generate_relation_name(Oid relid, List *namespaces);
 extern char * generate_qualified_relation_name(Oid relid);
 extern char * generate_operator_name(Oid operid, Oid arg1, Oid arg2);
diff --git a/src/include/distributed/version_compat.h b/src/include/distributed/version_compat.h
index 8d5e8d663..1bbdd4334 100644
--- a/src/include/distributed/version_compat.h
+++ b/src/include/distributed/version_compat.h
@@ -62,6 +62,7 @@
 #define RelationGetPartitionDesc_compat(a, b) RelationGetPartitionDesc(a, b)
 #define make_simple_restrictinfo_compat(a, b) make_simple_restrictinfo(a, b)
 #define pull_varnos_compat(a, b) pull_varnos(a, b)
+#define pg_get_statisticsobj_worker_compat(a, b, c) pg_get_statisticsobj_worker(a, b, c)
 #else
 #define AlterTableStmtObjType(a) ((a)->relkind)
 #define F_NEXTVAL_COMPAT F_NEXTVAL_OID
@@ -98,6 +99,7 @@
 #define PQ_LARGE_MESSAGE_LIMIT 0
 #define make_simple_restrictinfo_compat(a, b) make_simple_restrictinfo(b)
 #define pull_varnos_compat(a, b) pull_varnos(b)
+#define pg_get_statisticsobj_worker_compat(a, b, c) pg_get_statisticsobj_worker(a, c)
 #endif
 
 #if PG_VERSION_NUM >= PG_VERSION_13