diff --git a/src/backend/distributed/operations/shard_split.c b/src/backend/distributed/operations/shard_split.c index 22368d957..862454817 100644 --- a/src/backend/distributed/operations/shard_split.c +++ b/src/backend/distributed/operations/shard_split.c @@ -798,7 +798,7 @@ DropShardList(List *shardIntervalList) { ListCell *commandCell = NULL; - /* send the commands one by one */ + /* send the commands one by one (calls citus_internal_delete_shard_metadata internally) */ List *shardMetadataDeleteCommandList = ShardDeleteCommandList(shardInterval); foreach(commandCell, shardMetadataDeleteCommandList) { diff --git a/src/backend/distributed/operations/worker_split_copy_udf.c b/src/backend/distributed/operations/worker_split_copy_udf.c index 7f3bb4b31..524bdf7d5 100644 --- a/src/backend/distributed/operations/worker_split_copy_udf.c +++ b/src/backend/distributed/operations/worker_split_copy_udf.c @@ -15,7 +15,6 @@ #include "distributed/listutils.h" #include "distributed/multi_executor.h" #include "distributed/worker_shard_copy.h" -#include "distributed/worker_split_copy.h" #include "distributed/intermediate_results.h" #include "distributed/citus_ruleutils.h"