Mark failed placements as inactive immediately after COPY

2017-01-24 12:55:15 +01:00 · 2017-01-24 12:55:15 +01:00 · f56454360c
parent b1626887d5
commit f56454360c
1 changed files with 3 additions and 0 deletions
--- 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)