diff --git a/src/backend/distributed/commands/multi_copy.c b/src/backend/distributed/commands/multi_copy.c index 48de9ee86..b69a06799 100644 --- a/src/backend/distributed/commands/multi_copy.c +++ b/src/backend/distributed/commands/multi_copy.c @@ -536,6 +536,9 @@ CopyToExistingShards(CopyStmt *copyStatement, char *completionTag) EndCopyFrom(copyState); heap_close(distributedRelation, NoLock); + /* mark failed placements as inactive */ + CheckForFailedPlacements(true, CoordinatedTransactionUses2PC); + CHECK_FOR_INTERRUPTS(); if (completionTag != NULL)