diff --git a/src/backend/distributed/executor/multi_executor.c b/src/backend/distributed/executor/multi_executor.c index dd2c26733..8125cfaef 100644 --- a/src/backend/distributed/executor/multi_executor.c +++ b/src/backend/distributed/executor/multi_executor.c @@ -288,7 +288,15 @@ LoadTuplesIntoTupleStore(CitusScanState *citusScanState, Job *workerJob) if (BinaryMasterCopyFormat) { - DefElem *copyOption = makeDefElem("format", (Node *) makeString("binary")); + DefElem *copyOption = NULL; + +#if (PG_VERSION_NUM >= 100000) + int location = -1; /* "unknown" token location */ + copyOption = makeDefElem("format", (Node *) makeString("binary"), location); +#else + copyOption = makeDefElem("format", (Node *) makeString("binary")); +#endif + copyOptions = lappend(copyOptions, copyOption); } diff --git a/src/backend/distributed/worker/worker_data_fetch_protocol.c b/src/backend/distributed/worker/worker_data_fetch_protocol.c index 0422de4ec..8d6852a57 100644 --- a/src/backend/distributed/worker/worker_data_fetch_protocol.c +++ b/src/backend/distributed/worker/worker_data_fetch_protocol.c @@ -1404,6 +1404,11 @@ SetDefElemArg(AlterSeqStmt *statement, const char *name, Node *arg) } } +#if (PG_VERSION_NUM >= 100000) + defElem = makeDefElem((char *) name, arg, -1); +#else defElem = makeDefElem((char *) name, arg); +#endif + statement->options = lappend(statement->options, defElem); } diff --git a/src/backend/distributed/worker/worker_merge_protocol.c b/src/backend/distributed/worker/worker_merge_protocol.c index f1714e709..dc33311e5 100644 --- a/src/backend/distributed/worker/worker_merge_protocol.c +++ b/src/backend/distributed/worker/worker_merge_protocol.c @@ -510,7 +510,12 @@ CopyTaskFilesFromDirectory(StringInfo schemaName, StringInfo relationName, copyStatement = CopyStatement(relation, fullFilename->data); if (BinaryWorkerCopyFormat) { +#if (PG_VERSION_NUM >= 100000) + DefElem *copyOption = makeDefElem("format", (Node *) makeString("binary"), + -1); +#else DefElem *copyOption = makeDefElem("format", (Node *) makeString("binary")); +#endif copyStatement->options = list_make1(copyOption); }