Add check for connection failures during multishard update (#1765)

2017-11-07 12:33:25 +02:00 · 2017-11-07 12:33:25 +02:00 · 4e3d633ebf
parent 731b1254f9
commit 4e3d633ebf
1 changed files with 5 additions and 2 deletions
--- a/src/backend/distributed/executor/multi_router_executor.c
+++ b/src/backend/distributed/executor/multi_router_executor.c
@ -1141,8 +1141,11 @@ ExecuteModifyTasks(List *taskList, bool expectResults, ParamListInfo paramListIn
 											 &currentAffectedTupleCount);
 			}

-			/* should have rolled back on error */
-			Assert(queryOK);
+			/* We error out if the worker fails to return a result for the query. */
+			if (!queryOK)
+			{
+				ReportConnectionError(connection, ERROR);
+			}

 			if (placementIndex == 0)
 			{