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();