diff --git a/src/backend/distributed/planner/distributed_planner.c b/src/backend/distributed/planner/distributed_planner.c
index 738b3b37e..4c22b4f19 100644
--- a/src/backend/distributed/planner/distributed_planner.c
+++ b/src/backend/distributed/planner/distributed_planner.c
@@ -127,7 +127,12 @@ static PlannedStmt * PlanDistributedStmt(DistributedPlanningContext *planContext
 
 /* Distributed planner hook */
 PlannedStmt *
-distributed_planner(Query *parse, int cursorOptions, ParamListInfo boundParams)
+distributed_planner(Query *parse,
+	#if PG_VERSION_NUM >= PG_VERSION_13
+	const char *query_string,
+	#endif
+ 	int cursorOptions,
+	ParamListInfo boundParams)
 {
 	bool needsDistributedPlanning = false;
 	bool fastPathRouterQuery = false;
diff --git a/src/include/distributed/distributed_planner.h b/src/include/distributed/distributed_planner.h
index 581eeb948..9a71b939c 100644
--- a/src/include/distributed/distributed_planner.h
+++ b/src/include/distributed/distributed_planner.h
@@ -183,8 +183,13 @@ typedef struct CitusCustomScanPath
 } CitusCustomScanPath;
 
 
-extern PlannedStmt * distributed_planner(Query *parse, int cursorOptions,
-										 ParamListInfo boundParams);
+extern PlannedStmt * distributed_planner(
+	Query *parse,
+	#if PG_VERSION_NUM >= PG_VERSION_13
+	const char *query_string,
+	#endif 
+	int cursorOptions,
+	ParamListInfo boundParams);
 extern List * ExtractRangeTableEntryList(Query *query);
 extern List * ExtractReferenceTableRTEList(List *rteList);
 extern bool NeedsDistributedPlanning(Query *query);