You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/01 13:43:00 UTC

[jira] [Assigned] (FLINK-9494) Race condition in Dispatcher with concurrent granting and revoking of leaderhship

     [ https://issues.apache.org/jira/browse/FLINK-9494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Till Rohrmann reassigned FLINK-9494:
------------------------------------

    Assignee: Till Rohrmann

> Race condition in Dispatcher with concurrent granting and revoking of leaderhship
> ---------------------------------------------------------------------------------
>
>                 Key: FLINK-9494
>                 URL: https://issues.apache.org/jira/browse/FLINK-9494
>             Project: Flink
>          Issue Type: Bug
>          Components: Distributed Coordination
>    Affects Versions: 1.5.0
>            Reporter: Till Rohrmann
>            Assignee: Till Rohrmann
>            Priority: Critical
>             Fix For: 1.6.0, 1.5.1
>
>
> The {{Dispatcher}} contains a race condition when an instance is granted leadership and then quickly afterwards gets the leadership revoked. The problem is that we don't check in the recovered jobs future callback that we still have the leadership. This can lead to a corrupted state of the {{Dispatcher}}.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)