[
https://issues.apache.org/jira/browse/FLINK-5305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-5305:
----------------------------------
Component/s: API / DataSet
> Documentation of collect() should mention parameter akka.framesize
> ------------------------------------------------------------------
>
> Key: FLINK-5305
> URL: https://issues.apache.org/jira/browse/FLINK-5305
> Project: Flink
> Issue Type: Improvement
> Components: API / DataSet, Documentation
> Affects Versions: 1.1.3
> Reporter: Arnaud Linz
> Priority: Minor
>
> When calling collect() on a big dataset, if the data size exceeds the value
> of akka.framesize, which is 10Mb by default, the collect() freezes and some
> "akka payload size exceeded" logs appear in the yarn logs (but neither in the
> flink console output nor UI logs).
> 10Mb is not that big, and its relation to akka.framesize is hard to find in
> the documentation (in Flink internals section). I believe that the "easy to
> find" collect documentation should mention this parameter to save hours of
> users time.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
