One of my colleagues found it today when we where hunting bugs today. We where using the latest 0.10 version pulled from maven this morning. The program we where testing is new code so I cant tell you if the behavior has changed or if it was always like this.
On Fri, Oct 2, 2015 at 7:46 PM, Stephan Ewen <se...@apache.org> wrote: > 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 > > >
