From c0e2a25d92845763fd8d3de5947792323b6a5715 Mon Sep 17 00:00:00 2001
From: Jason Petersen <jason@citusdata.com>
Date: Thu, 20 Apr 2017 19:08:31 -0600
Subject: [PATCH] Handle CreateSchemaCommand changes

Now expects a statement location and length, though passing -1 for both
preserves existing behavior.
---
 src/backend/distributed/worker/task_tracker_protocol.c | 5 +++++
 1 file changed, 5 insertions(+)

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 */