Re: Consumption stops on some Kafka partitions in job running on Flink 1.15.2

Hi Samuel, Maybe related to this https://issues.apache.org/jira/browse/FLINK-28975? See also: - https://stackoverflow.com/questions/72654182/flink-interval-join-datastream-with-kafkasource-drops-all-records I left a similar comment in your SO post. Regards, Salva On Mon, Nov 7, 2022 at 7:27 AM

Strange issue with exactly once checkpoints and the kafka sink

I had a Flink 1.15.1 job configured with ``` execution.checkpointing.mode=`EXACTLY_ONCE` ``` that was failing with the following error ``` Sink: Committer (2/2)#732 (36640a337c6ccdc733d176b18adab979) switched from INITIALIZING to FAILED with failure cause: java.lang.IllegalStateException: Failed

Consumption stops on some Kafka partitions in job running on Flink 1.15.2

Hello, At work we are using Flink to store timers and notify us when they are triggered. It's been working great over several versions over the years. Flink 1.5 -> Flink 1.9 -> Flink 1.15.2. A few months ago we upgraded from Flink 1.9 to Flink 1.15.2. In the process we had to upgrade all the Flin