You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by rmetzger0 <rm...@apache.org> on 2015/02/06 17:08:04 UTC

Re: Not enough buffers when running Flink jar on cluster

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.