I think these operations were recently moved to the internal state interface. Did the behavior change then?
@Marton or Gyula, can you comment? Is it per chance not mapped to the partitioned state? On Fri, Oct 2, 2015 at 6:37 PM, Martin Neumann <mneum...@sics.se> wrote: > 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 >
