diff --git a/src/backend/executor/nodeGather.c b/src/backend/executor/nodeGather.c
index 850c67e022..513940477c 100644
--- a/src/backend/executor/nodeGather.c
+++ b/src/backend/executor/nodeGather.c
@@ -341,7 +341,7 @@ gather_readnext(GatherState *gatherstate)
 			--gatherstate->nreaders;
 			if (gatherstate->nreaders == 0)
 			{
-				ExecShutdownGather(gatherstate);
+				ExecShutdownGatherWorkers(gatherstate);
 				return NULL;
 			}
 			else