diff --git a/src/backend/distributed/commands/multi_copy.c b/src/backend/distributed/commands/multi_copy.c index 8a7b19276..df3f1027d 100644 --- a/src/backend/distributed/commands/multi_copy.c +++ b/src/backend/distributed/commands/multi_copy.c @@ -408,7 +408,6 @@ CopyToExistingShards(CopyStmt *copyStatement, char *completionTag) PG_TRY(); { - /* initialize copy state to read from COPY data source */ #if (PG_VERSION_NUM >= 100000) copyState = BeginCopyFrom(NULL, diff --git a/src/backend/distributed/commands/transmit.c b/src/backend/distributed/commands/transmit.c index 319602b00..629958909 100644 --- a/src/backend/distributed/commands/transmit.c +++ b/src/backend/distributed/commands/transmit.c @@ -50,7 +50,6 @@ RedirectCopyDataToRegularFile(const char *filename) PG_TRY(); { - SendCopyInStart(); copyDone = ReceiveCopyData(copyData);