From f56454360ce4b82d6bd27a95c7d0148907ec54db Mon Sep 17 00:00:00 2001 From: Marco Slot Date: Tue, 24 Jan 2017 12:55:15 +0100 Subject: [PATCH] Mark failed placements as inactive immediately after COPY --- src/backend/distributed/commands/multi_copy.c | 3 +++ 1 file changed, 3 insertions(+) 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)