Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/6159
@StefanRRichter Sorry that I didn't take a look again yesterday, I was a
bit too busy at that time. I had a look at the fix for the
`CopyOnWriteStateTable`, I afraid it's still a partial fix, I just create a
JIRA for it and will give a PR for it very soon.
In short, the another partial problem is that we reuse the `snaphotData` as
the output array when partitioning the data, but the `snapshotData` is max
length is `1 << 30`. So when the records in `CopyOnWriteStateTable` is more
than `1 << 30` (e.g. 1 <<30 + 1), then the check
`Preconditions.checkState(partitioningDestination.length >= numberOfElements);`
could be failed.
---
