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

Fully qualify copy udf name. Run Reindent

pull/6029/head
Nitish Upreti 2022-07-09 16:35:10 -07:00
parent a6ca23feda
commit 5a1a8d5dcb
2 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/backend/distributed/operations/shard_split.c
View File

@ -652,7 +652,7 @@ CreateSplitCopyCommand(ShardInterval *sourceShardSplitInterval,
appendStringInfo(splitCopyInfoArray, "]"); appendStringInfo(splitCopyInfoArray, "]");
StringInfo splitCopyUdf = makeStringInfo(); StringInfo splitCopyUdf = makeStringInfo();
appendStringInfo(splitCopyUdf, "SELECT worker_split_copy(%lu, %s);", appendStringInfo(splitCopyUdf, "SELECT pg_catalog.worker_split_copy(%lu, %s);",
sourceShardSplitInterval->shardId, sourceShardSplitInterval->shardId,
splitCopyInfoArray->data); splitCopyInfoArray->data);

6
src/backend/distributed/operations/worker_split_copy_udf.c
View File

@ -81,11 +81,13 @@ worker_split_copy(PG_FUNCTION_ARGS)
shardIntervalToSplitCopy, shardIntervalToSplitCopy,
splitCopyInfoList); splitCopyInfoList);
Oid sourceShardToCopySchemaOId = get_rel_namespace(shardIntervalToSplitCopy->relationId); Oid sourceShardToCopySchemaOId = get_rel_namespace(
shardIntervalToSplitCopy->relationId);
char *sourceShardToCopySchemaName = get_namespace_name(sourceShardToCopySchemaOId); char *sourceShardToCopySchemaName = get_namespace_name(sourceShardToCopySchemaOId);
char *sourceShardToCopyName = get_rel_name(shardIntervalToSplitCopy->relationId); char *sourceShardToCopyName = get_rel_name(shardIntervalToSplitCopy->relationId);
AppendShardIdToName(&sourceShardToCopyName, shardIdToSplitCopy); AppendShardIdToName(&sourceShardToCopyName, shardIdToSplitCopy);
char *sourceShardToCopyQualifiedName = quote_qualified_identifier(sourceShardToCopySchemaName, char *sourceShardToCopyQualifiedName = quote_qualified_identifier(
sourceShardToCopySchemaName,
sourceShardToCopyName); sourceShardToCopyName);
StringInfo selectShardQueryForCopy = makeStringInfo(); StringInfo selectShardQueryForCopy = makeStringInfo();