Hey, Thanks for reporting the problem, Martin. I have not merged the PR Stephan is referring to yet. [1] There I am cleaning up some of the internals too. Just out of curiosity, could you share the code for the failing test please?
[1] https://github.com/apache/flink/pull/1155 On Fri, Oct 2, 2015 at 8:26 PM, Martin Neumann <mneum...@sics.se> wrote: > 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 > > > > > >
