Hi
I am running a flink application with parallelism 64, I left the
checkpoint timeout default value, which is 10minutes, the state size is less
than 1MB, I am using the FsStateBackend.
The application triggers some checkpoints but all of them fails due to
"Checkpoint expired before completing”, I check the checkpoint history, found
that there are 63 subtask acknowledge, but one left n/a, and also the alignment
duration is quite long, about 5m27s.
I want to know why there is one subtask does not acknowledge? And
because the alignment duration is long, what will influent the alignment
duration?
Thank a lot.
Best
Henry
