Re: Left join query not clearing state after migrating from 1.9.0 to 1.14.3

2022-03-09 Thread Roman Khachatryan
Hi Prakhar, Thanks for sharing this > Also, can you give us an idea of exactly what details you are looking for? It would be helpful to know the sizes of different parts of the checkpoint and the timings (e.g. sync/async phases, alignment duration, etc.) [1] Could you please share: 1.

Re: Left join query not clearing state after migrating from 1.9.0 to 1.14.3

2022-03-08 Thread Prakhar Mathur
Hi Roman, Thanks for the reply, here is the screenshot of the latest failed checkpoint. [image: Screenshot 2022-03-09 at 11.44.46 AM.png] I couldn't find the details for the last successful one as we only store the last 10 checkpoints' details. Also, can you give us an idea of exactly what

Re: Left join query not clearing state after migrating from 1.9.0 to 1.14.3

2022-03-08 Thread Roman Khachatryan
Hi Prakhar, Could you please share the statistics about the last successful and failed checkpoints, e.g. from the UI. Ideally, with detailed breakdown for the operators that seems problematic. Regards, Roman On Fri, Mar 4, 2022 at 8:48 AM Prakhar Mathur wrote: > > Hi, > > Can someone kindly

Re: Left join query not clearing state after migrating from 1.9.0 to 1.14.3

2022-03-03 Thread Prakhar Mathur
Hi, Can someone kindly help and take a look at this? It's a major blocker for us. Thanks, Prakhar On Wed, Mar 2, 2022 at 2:11 PM Prakhar Mathur wrote: > Hello, > > We recently did a migration of our Flink jobs from version 1.9.0 to > 1.14.3. These jobs consume from Kafka and produce to