diff --git a/src/backend/distributed/worker/worker_merge_protocol.c b/src/backend/distributed/worker/worker_merge_protocol.c
index 84cdbf9e3..d22ad1451 100644
--- a/src/backend/distributed/worker/worker_merge_protocol.c
+++ b/src/backend/distributed/worker/worker_merge_protocol.c
@@ -394,7 +394,12 @@ CreateTaskTable(StringInfo schemaName, StringInfo relationName,
 
 	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);
+#endif
 	relationId = relationObject.objectId;
 
 	Assert(relationId != InvalidOid);