Thanks for your response! Recommendation to decrease allotted memory? Which allotted memory should be decreased?
I tried decreasing taskmanager.memory.fraction to give more memory to user managed operations, that doesn't work beyond a point. Also tried increasing containerized.heap-cutoff-ratio, that didn't work either. What eventually solved the problem was increasing parallelism - throwing in many more task managers. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/