Good Morning, Afternoon and Evening! my Flink app is working fine with i use single parallelism but when i run it with more than one it throwing this exception

key group from 0 to 6 does not contain 120.........

is there any one who know what exactly is happening ? Thank you in advance 🙏.

Perhaps you have a non-deterministic key selector function.

thank you so much for replying to my question, i didn’t use any fancy key selector i just used the normal one

.keyBy(new KeySelector<Tuple3<String, RateRule, Long>, Tuple2<String, RateRule>>() {
                    @Override
                    public Tuple2<String, RateRule> getKey(Tuple3<String, RateRule, Long> value) throws Exception {
                        return new Tuple2<>(value.f0, value.f1);
                    }
                })