Feifan Wang created FLINK-31414:
-----------------------------------
Summary: exceptions in the alignment timer are ignored
Key: FLINK-31414
URL: https://issues.apache.org/jira/browse/FLINK-31414
Project: Flink
Issue Type: Bug
Components: Runtime / Checkpointing
Reporter: Feifan Wang
Alignment timer task in alternating aligned checkpoint run as a future task in
mailbox thread, leads to exceptions
([SingleCheckpointBarrierHandler#registerAlignmentTimer()|https://github.com/apache/flink/blob/65ab8e820a3714d2134dfb4c9772a10c998bd45a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/SingleCheckpointBarrierHandler.java#L327])
are ignored.
see :
[BarrierAlignmentUtil#createRegisterTimerCallback()|https://github.com/apache/flink/blob/65ab8e820a3714d2134dfb4c9772a10c998bd45a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/BarrierAlignmentUtil.java#L50]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
