diff --git a/src/backend/distributed/executor/multi_task_tracker_executor.c b/src/backend/distributed/executor/multi_task_tracker_executor.c index 2f57906ab..9bf24f6b3 100644 --- a/src/backend/distributed/executor/multi_task_tracker_executor.c +++ b/src/backend/distributed/executor/multi_task_tracker_executor.c @@ -2939,8 +2939,9 @@ TrackerHashCleanupJob(HTAB *taskTrackerHash, Task *jobCleanupTask) taskTracker); } } - else if (timedOut) + else if (resultStatus == CLIENT_RESULT_UNAVAILABLE || timedOut) { + /* CLIENT_RESULT_UNAVAILABLE is returned if the connection failed somehow */ ereport(WARNING, (errmsg("could not receive response for cleanup query " "result for job " UINT64_FORMAT " on node " "\"%s:%u\" with status %d",