[jira] [Created] (FLINK-22961) Incorrect calculation of alignment timeout for LocalInputChannel

[Shang Yuanchun (Jira)]

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)