Anton Kalashnikov created FLINK-22961:
-----------------------------------------
Summary: Incorrect calculation of alignment timeout for
LocalInputChannel
Key: FLINK-22961
URL: https://issues.apache.org/jira/browse/FLINK-22961
Project: Flink
Issue Type: Bug
Reporter: Anton Kalashnikov
Assignee: Anton Kalashnikov
Right now, the calculation of alignment timeout happens inside of
SingleCheckpointBarrierHandler(org.apache.flink.streaming.runtime.io.checkpointing.SingleCheckpointBarrierHandler.ControllerImpl#isTimedOut)
and it based on firstBarrierArrivalTime. the firstBarrierArrivalTime
recalculated only when barrier announcement was received but if we receive the
first checkpoint barrier from the LocalInputChannel which doesn't support
announcement, the calculation of alignment timeout will be based on the
firstBarrierArrivalTime from the previous checkpoint which is wrong.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
