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

Posted to issues@flink.apache.org by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/05/31 12:38:11 UTC

[jira] [Updated] (FLINK-5861) TaskManager's components support updating JobManagerConnection

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

Robert Metzger updated FLINK-5861:
----------------------------------
    Fix Version/s:     (was: 1.3.0)
                   1.4.0

> TaskManager's components support updating JobManagerConnection
> --------------------------------------------------------------
>
>                 Key: FLINK-5861
>                 URL: https://issues.apache.org/jira/browse/FLINK-5861
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Distributed Coordination, JobManager
>            Reporter: Biao Liu
>            Assignee: Biao Liu
>             Fix For: 1.4.0
>
>
> Some components in TaskManager, such as TaskManagerActions, CheckpointResponder, ResultPartitionConsumableNotifier, PartitionProducerStateChecker, need to support updating JobManagerConnection. So when JobManager fails and recovers, the tasks who keep old JobManagerConnection can be notified to update JobManagerConnection. The tasks can continue doing their jobs without failure.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)