What could be the reason for failure - Key group is not in KeyGroupRange.

Hi, I am using apache flink 1.18 and running this locally with rocksdb as state backend. So far my pipeline was working fine and was making few adjustments and then it started failing with some weird exception: 2024-11-24 21:54:27,440 WARN org.apache.flink.runtime.taskmanager.Task [] - Task (1/4)#

Re: Key group is not in KeyGroupRange

The problem was caused by by concurrent access to the ValueState by another thread. Thanks to Yun Tang for pointing this out. Discussion is in FLINK-18637 On Tue, Jul 21, 2020 at

Re: Key group is not in KeyGroupRange

I should have mentioned, I've opened a bug for it https://issues.apache.org/jira/browse/FLINK-18637. So the discussion moved there. On Tue, Jul 14, 2020 at 2:03 PM Ori Popowski wrote: > I'm getting this error when creating a savepoint. I've read in > https://issues.apache.org/jira/browse/FLINK-1

Re: Key group is not in KeyGroupRange

Looks like this thread is already being resolved in https://issues.apache.org/jira/browse/FLINK-18637 On Tue, Jul 21, 2020 at 10:26 AM Robert Metzger wrote: > Hi Ori, > thanks a lot for your email. Which version of Flink are you using? > > On Tue, Jul 14, 2020 at 1:03 PM Ori Popowski wrote: > >

Key group is not in KeyGroupRange

I'm getting this error when creating a savepoint. I've read in https://issues.apache.org/jira/browse/FLINK-16193 that it's caused by unstable hashcode or equals on the key, or improper use of reinterpretAsKeyedStream. My key is a string and I don't use reinterpretAsKeyedStream, so what's going on?