In the class org.apache.flink.runtime.io.network.api.writer.RecordWriter, it has same number of serializers with the numChannels. If I first operator has 500 parallels and the next operator has 1000 parallels. And every message in flink is 2MB. The job takes 500 * 1000 * 2MB as 1TB memory in totally!!! Can I do anything to reduce the memory usage.
-- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
