diff --git a/src/backend/distributed/operations/split_shard_replication_setup.c b/src/backend/distributed/operations/worker_split_shard_replication_setup_udf.c
similarity index 99%
rename from src/backend/distributed/operations/split_shard_replication_setup.c
rename to src/backend/distributed/operations/worker_split_shard_replication_setup_udf.c
index 0d9a2b8f6..abcfc042a 100644
--- a/src/backend/distributed/operations/split_shard_replication_setup.c
+++ b/src/backend/distributed/operations/worker_split_shard_replication_setup_udf.c
@@ -1,6 +1,6 @@
 /*-------------------------------------------------------------------------
  *
- * split_shard_replication_setup.c
+ * worker_split_shard_replication_setup.c
  *    This file contains functions to setup information about list of shards
  *    that are being split.
  *
diff --git a/src/backend/distributed/shardsplit/shardsplit_logical_replication.c b/src/backend/distributed/shardsplit/shardsplit_logical_replication.c
index 0504ad860..00c283361 100644
--- a/src/backend/distributed/shardsplit/shardsplit_logical_replication.c
+++ b/src/backend/distributed/shardsplit/shardsplit_logical_replication.c
@@ -218,26 +218,6 @@ PrintShardSplitPubSubMetadata(ShardSplitSubscriberMetadata *shardSplitMetadata)
 	printf("\n");
 }
 
-
-/* static void */
-/* CreateShardSplitPublications(MultiConnection *sourceConnection, */
-/*                           List *shardSplitPubSubMetadataList) */
-/* { */
-/*  ShardSplitSubscriberMetadata *shardSplitPubSubMetadata = NULL; */
-/*  foreach_ptr(shardSplitPubSubMetadata, shardSplitPubSubMetadataList) */
-/*  { */
-/*      uint32 publicationForNodeId = shardSplitPubSubMetadata->slotInfo->targetNodeId; */
-/*      Oid tableOwnerId = shardSplitPubSubMetadata->tableOwnerId; */
-
-/*      CreateShardSplitPublicationForNode(sourceConnection, */
-/*                                         shardSplitPubSubMetadata-> */
-/*                                         shardIntervalListForSubscription, */
-/*                                         publicationForNodeId, */
-/*                                         tableOwnerId); */
-/*  } */
-/* } */
-
-
 void
 CreateShardSplitSubscriptions(List *targetNodeConnectionList,
 							  List *shardSplitPubSubMetadataList,