diff --git a/src/backend/distributed/worker/task_tracker_protocol.c b/src/backend/distributed/worker/task_tracker_protocol.c
index 25634f953..d1972b229 100644
--- a/src/backend/distributed/worker/task_tracker_protocol.c
+++ b/src/backend/distributed/worker/task_tracker_protocol.c
@@ -295,7 +295,12 @@ CreateJobSchema(StringInfo schemaName)
 	createSchemaStmt->schemaElts = NIL;
 
 	/* actually create schema with the current user as owner */
+#if (PG_VERSION_NUM >= 100000)
+	CreateSchemaCommand(createSchemaStmt, queryString, -1, -1);
+#else
 	CreateSchemaCommand(createSchemaStmt, queryString);
+#endif
+
 	CommandCounterIncrement();
 
 	/* and reset environment */