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 Nicolas:
Are you using a custom partitioner? If so, you might need to check if the
Partitioners#partition has returned a value that is greater than or equal to
the parallelism of the downstream tasks. The expected return value should be in
the interval [0, the parallelism of the downstr
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
