flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-5861) TaskManager's components support updating JobManagerConnection
Date Thu, 23 Feb 2017 05:53:44 GMT

    [ https://issues.apache.org/jira/browse/FLINK-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15879923#comment-15879923

ASF GitHub Bot commented on FLINK-5861:

GitHub user ifndef-SleePy opened a pull request:


    [FLINK-5861] Components of TaskManager support updating JobManagerConnection


You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/alibaba/flink jira-5861

Alternatively you can review and apply these changes as the patch at:


To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #3395


> 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
> 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

View raw message