Andrey, A small clarification. The tweaked WordCount I posted earlier doesn't illustrate the issue I originally explained, i.e. the one where there's a bigger operator and a smallest possible windows operator. Instead, the modified WordCount illustrates the degraded performance of a very simple Flink application when using managed memory and increasing parallelism over a certain treshold. The performance is not degraded if not using managed memory (and parallelism is increased).
I was hoping this kind of simple program would be easier to debug / profile. I can also submit the more complex test with the bigger operator and and a window operator. There's just gonna be more code to read. Can I attach a file here or how should I submit a larger chuck of code? Regards, Juha -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
