If you have a function processed by each which inserts new tuples into a stream AND that stream does not have any fields, an NPE is awaiting you.  This tweak avoids the NPE.