Re: Flink Checkpoint times out with checkpointed data size doubles every checkpoint.

2023-06-20 Thread Prabhu Joseph
u accumulate the state in a big window, e.g. in a 2 hour >> Tumbling window the maximum job state will be reached in two hours only. So >> your job should be scaled or optimized. >> >> Best >> Alex >> >> On Tue, Jun 20, 2023 at 10:39 AM Prabhu Joseph < >

Re: Flink Checkpoint times out with checkpointed data size doubles every checkpoint.

2023-06-20 Thread Shammon FY
Tumbling window the maximum job state will be reached in two hours only. So > your job should be scaled or optimized. > > Best > Alex > > On Tue, Jun 20, 2023 at 10:39 AM Prabhu Joseph > wrote: > >> Hi, >> >> Flink Checkpoint times out with checkpointed dat

Re: Flink Checkpoint times out with checkpointed data size doubles every checkpoint.

2023-06-20 Thread Alex Nitavsky
the state in a big window, e.g. in a 2 hour Tumbling window the maximum job state will be reached in two hours only. So your job should be scaled or optimized. Best Alex On Tue, Jun 20, 2023 at 10:39 AM Prabhu Joseph wrote: > Hi, > > Flink Checkpoint times out with checkpointed data

Flink Checkpoint times out with checkpointed data size doubles every checkpoint.

2023-06-20 Thread Prabhu Joseph
Hi, Flink Checkpoint times out with checkpointed data size doubles every checkpoint. Any ideas on what could be wrong in the application or how to debug this? [image: checkpoint_issue.png]