On 2019/05/30 14:12:35, bjb...@gmail.com wrote:
> Hi everyone,
>
> I've made a Beam pipeline that makes use of a SideInput which in my case is a
> Map of key/values. I'm running Flink (1.7.1) on yarn (hadoop 2.6.0). I've
> found that if my map is small enough everything works fine but if I
Hi everyone,
I've made a Beam pipeline that makes use of a SideInput which in my case is a
Map of key/values. I'm running Flink (1.7.1) on yarn (hadoop 2.6.0). I've found
that if my map is small enough everything works fine but if I make it large
enough (2-3MB) the pipeline fails with,
org.apa
