RE: Re: Looking for help with Job Initialisation issue

2024-05-08 Thread Abhi Sagar Khatri via user
ad dump to see where the > operator is getting stuck. > > Best, > Biao Geng > > Abhi Sagar Khatri via user 于2024年4月30日周二 19:38写道: > > > > Some more context: Our job graph has 5 different Tasks/operators/flink functions of which we are seeing this issue every time

Re: Looking for help with Job Initialisation issue

2024-04-30 Thread Abhi Sagar Khatri via user
Some more context: Our job graph has 5 different Tasks/operators/flink functions of which we are seeing this issue every time in a particular operator We’re using Unaligned checkpoints. With aligned checkpoint we don’t see this issue but the checkpoint duration in that case is very high and causes

Looking for help with Job Initialisation issue

2024-04-30 Thread Abhi Sagar Khatri via user
Hi Flink folks, Our team has been working on a Flink service. After completing the service development, we moved on to the Job Stabilisation exercises at the production load. During high load, we see that if the job restarts (mostly due to the "org.apache.flink.util.FlinkExpectedException: The Task