diff --git a/src/backend/distributed/utils/tuplestore.c b/src/backend/distributed/utils/tuplestore.c
index 4473c1f3e..f6215cd15 100644
--- a/src/backend/distributed/utils/tuplestore.c
+++ b/src/backend/distributed/utils/tuplestore.c
@@ -77,7 +77,7 @@ SetupTuplestore(FunctionCallInfo fcinfo, TupleDesc *tupleDescriptor)
 
 	MemoryContext oldContext = MemoryContextSwitchTo(perQueryContext);
 	Tuplestorestate *tupstore = tuplestore_begin_heap(true, false, work_mem);
-	resultSet->returnMode = SFRM_Materialize;
+	resultSet->returnMode = SFRM_ValuePerCall;
 	resultSet->setResult = tupstore;
 	resultSet->setDesc = *tupleDescriptor;
 	MemoryContextSwitchTo(oldContext);