external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

PlacementExecutionDone: We may mark placements as failed multiple times, but should only act the first time.

pull/3382/head
Philip Dubé 2020-01-14 00:18:24 +00:00
parent fd5935d798
commit 4989c9a15c
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/backend/distributed/executor/adaptive_executor.c
View File

@ -3491,6 +3491,15 @@ PlacementExecutionDone(TaskPlacementExecution *placementExecution, bool succeede
TaskExecutionState executionState = shardCommandExecution->executionState; TaskExecutionState executionState = shardCommandExecution->executionState;
bool failedPlacementExecutionIsOnPendingQueue = false; bool failedPlacementExecutionIsOnPendingQueue = false;
if (placementExecution->executionState == PLACEMENT_EXECUTION_FAILED)
{
/*
* We may mark placements as failed multiple times, but should only act
* the first time. Nor should we accept success after failure.
*/
return;
}
/* mark the placement execution as finished */ /* mark the placement execution as finished */
if (succeeded) if (succeeded)
{ {