Thanks a lot for all the help! I was able to figure out the bug just now. I had some extra code in the coFlatMap function(emitting stats) which was inefficient and causing high GC usage. Fixing that fixed the issue.
-- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
