Hi, yes, I used the old Scala API, and now ported to the new one. One thing I noticed is the different memory behaviour. 0.7 seems to allocate more memory (but when I look at the documentation for 0.6 and 0.7 the value of taskmanager.memory.fraction did not change), and the garbage collection (therefore?) runs more often. Please find attached two profiling screenshots of the same flink program, in 0.6 and 0.7. Is there some way to set the taskmanager.memory.fraction for the local execution?
Stefan On Sat, Oct 18, 2014 at 8:52 PM, Stephan Ewen <[email protected]> wrote: > Hi! > > This may be due to many aspects: different startup behavior of the local > environment. Different deployment behavior, different shutdown behavior. > > Do you know where the time is spent? > > Stephan >
