diff --git a/src/backend/distributed/operations/worker_shard_copy.c b/src/backend/distributed/operations/worker_shard_copy.c index c4d69e9f2..68728dfb6 100644 --- a/src/backend/distributed/operations/worker_shard_copy.c +++ b/src/backend/distributed/operations/worker_shard_copy.c @@ -124,7 +124,8 @@ ConnectToRemoteAndStartCopy(ShardCopyDestReceiver *copyDest) ReportConnectionError(copyDest->connection, ERROR); } - PGresult *result = GetRemoteCommandResult(copyDest->connection, true /* raiseInterrupts */); + PGresult *result = GetRemoteCommandResult(copyDest->connection, + true /* raiseInterrupts */); if (PQresultStatus(result) != PGRES_COPY_IN) { ReportResultError(copyDest->connection, result, ERROR); @@ -331,6 +332,7 @@ CreateShardCopyDestReceiver(EState *executorState, return (DestReceiver *) copyDest; } + /* * ShardCopyDestReceiverDestroy frees the DestReceiver. */ diff --git a/src/backend/distributed/operations/worker_split_copy_udf.c b/src/backend/distributed/operations/worker_split_copy_udf.c index b782c2196..66da99845 100644 --- a/src/backend/distributed/operations/worker_split_copy_udf.c +++ b/src/backend/distributed/operations/worker_split_copy_udf.c @@ -75,6 +75,7 @@ worker_split_copy(PG_FUNCTION_ARGS) PG_RETURN_VOID(); } + /* Parse a single SplitCopyInfo Tuple */ static void ParseSplitCopyInfoDatum(Datum splitCopyInfoDatum, SplitCopyInfo **splitCopyInfo) diff --git a/src/test/regress/expected/citus_split_shard_by_split_points_local.out b/src/test/regress/expected/citus_split_shard_by_split_points_local.out deleted file mode 100644 index e69de29bb..000000000