external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Handle DefineRelation changes 

Now accepts the original query string; passing NULL is fine.
pull/1439/head
Jason Petersen 2017-04-20 19:42:11 -06:00
parent 39ed50c52f
commit 7cf2b48f64
No known key found for this signature in database
GPG Key ID: 9F1D3510D110ABA9
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/backend/distributed/worker/worker_merge_protocol.c
View File

@ -394,7 +394,12 @@ CreateTaskTable(StringInfo schemaName, StringInfo relationName,
createStatement = CreateStatement(relation, columnDefinitionList); createStatement = CreateStatement(relation, columnDefinitionList);
#if (PG_VERSION_NUM >= 100000)
relationObject = DefineRelation(createStatement, RELKIND_RELATION, InvalidOid, NULL,
NULL);
#else
relationObject = DefineRelation(createStatement, RELKIND_RELATION, InvalidOid, NULL); relationObject = DefineRelation(createStatement, RELKIND_RELATION, InvalidOid, NULL);
#endif
relationId = relationObject.objectId; relationId = relationObject.objectId;
Assert(relationId != InvalidOid); Assert(relationId != InvalidOid);