Hej, In one of my Programs I run a Fold on a GroupedDataStream. The aim is to aggregate the values in each group. It seems the aggregator in the Fold function is shared on operator level, so all groups that end up on the same operator get mashed together.
Is this the wanted behavior? If so, what do I have to do to separate them? cheers Martin
