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

2022-11-07 Thread Samuel Chase
great, if anyone can help clear this up for me. On Mon, Nov 7, 2022 at 2:18 PM Salva Alcántara wrote: > > Hi Samuel, > > I'm glad to hear that! Let us know how the problem is finally solved. > Personally I'd upgrade to 1.15.3. > > Salva > > On Mon, Nov 7

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

2022-11-07 Thread Samuel Chase
o 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 Mo

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

2022-11-06 Thread Samuel Chase
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