You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/06/23 06:50:00 UTC
[jira] [Closed] (FLINK-22961) Incorrect calculation of alignment
timeout for LocalInputChannel
[ https://issues.apache.org/jira/browse/FLINK-22961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Dawid Wysakowicz closed FLINK-22961.
------------------------------------
Resolution: Fixed
Fixed in:
* master
** 833983cd5717de0e448fa3c152be826eedc2eeae
* 1.13.2
** 644ba4dcea7e37b83ec3aab2f53245a6b1aca3ae
> Incorrect calculation of alignment timeout for LocalInputChannel
> ----------------------------------------------------------------
>
> Key: FLINK-22961
> URL: https://issues.apache.org/jira/browse/FLINK-22961
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Checkpointing
> Affects Versions: 1.14.0, 1.13.1
> Reporter: Anton Kalashnikov
> Assignee: Anton Kalashnikov
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.14.0, 1.13.2
>
>
> 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)