Hi Yun,
Indeed, that was it: a parallelism set to lower than what my custom partitioner
was computing.
Thanks
Nicolas
On Tue, Aug 6, 2019, at 4:47 AM, Yun Gao wrote:
> Hi Nicolas:
>
> Are you using a custom partitioner? If so, you might need to check if the
> Partitioners#partition has retu
Hi,
I have got a weird error after a few messages. I have first seen this error on
a deployed Flink cluster 1.7.1. Trying to figure it out, I am trying with a
local Flink 1.8.1. I still get this ArrayIndexOutOfBoundsException. I don't
have a precise scenario to reproduce it, but it is happening
