Hi, the number of required buffers depends a lot on the job. If a job needs to send data to operators running on other machines, it needs buffers to do that. Operations like reduce or join usually need many buffers. If you just have a bunch of chained mappers, the requirements are lower.
Increasing the number of buffers will really solve this problem. -- View this message in context: http://apache-flink-incubator-user-mailing-list-archive.2336050.n4.nabble.com/Not-enough-buffers-when-running-Flink-jar-on-cluster-tp699p702.html Sent from the Apache Flink (Incubator) User Mailing List archive. mailing list archive at Nabble.com.
