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
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
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