From 5a1a8d5dcb2719121a71efec4ef7bab37e30bd75 Mon Sep 17 00:00:00 2001 From: Nitish Upreti Date: Sat, 9 Jul 2022 16:35:10 -0700 Subject: [PATCH] Fully qualify copy udf name. Run Reindent --- src/backend/distributed/operations/shard_split.c | 2 +- src/backend/distributed/operations/worker_split_copy_udf.c | 6 ++++-- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/src/backend/distributed/operations/shard_split.c b/src/backend/distributed/operations/shard_split.c index f21e3d849..7411e39a6 100644 --- a/src/backend/distributed/operations/shard_split.c +++ b/src/backend/distributed/operations/shard_split.c @@ -652,7 +652,7 @@ CreateSplitCopyCommand(ShardInterval *sourceShardSplitInterval, appendStringInfo(splitCopyInfoArray, "]"); StringInfo splitCopyUdf = makeStringInfo(); - appendStringInfo(splitCopyUdf, "SELECT worker_split_copy(%lu, %s);", + appendStringInfo(splitCopyUdf, "SELECT pg_catalog.worker_split_copy(%lu, %s);", sourceShardSplitInterval->shardId, splitCopyInfoArray->data); diff --git a/src/backend/distributed/operations/worker_split_copy_udf.c b/src/backend/distributed/operations/worker_split_copy_udf.c index 053d1292f..63f7656fd 100644 --- a/src/backend/distributed/operations/worker_split_copy_udf.c +++ b/src/backend/distributed/operations/worker_split_copy_udf.c @@ -81,11 +81,13 @@ worker_split_copy(PG_FUNCTION_ARGS) shardIntervalToSplitCopy, splitCopyInfoList); - Oid sourceShardToCopySchemaOId = get_rel_namespace(shardIntervalToSplitCopy->relationId); + Oid sourceShardToCopySchemaOId = get_rel_namespace( + shardIntervalToSplitCopy->relationId); char *sourceShardToCopySchemaName = get_namespace_name(sourceShardToCopySchemaOId); char *sourceShardToCopyName = get_rel_name(shardIntervalToSplitCopy->relationId); AppendShardIdToName(&sourceShardToCopyName, shardIdToSplitCopy); - char *sourceShardToCopyQualifiedName = quote_qualified_identifier(sourceShardToCopySchemaName, + char *sourceShardToCopyQualifiedName = quote_qualified_identifier( + sourceShardToCopySchemaName, sourceShardToCopyName); StringInfo selectShardQueryForCopy = makeStringInfo();