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-5197) Late JobStatusChanged messages can interfere with running jobs
Date Wed, 30 Nov 2016 12:48:58 GMT

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

ASF GitHub Bot commented on FLINK-5197:

Github user tillrohrmann closed the pull request at:


> Late JobStatusChanged messages can interfere with running jobs
> --------------------------------------------------------------
>                 Key: FLINK-5197
>                 URL: https://issues.apache.org/jira/browse/FLINK-5197
>             Project: Flink
>          Issue Type: Bug
>          Components: JobManager
>    Affects Versions: 1.2.0, 1.1.3
>            Reporter: Till Rohrmann
>            Assignee: Till Rohrmann
>            Priority: Minor
>             Fix For: 1.2.0, 1.1.4
> When the {{JobManager}} receives a {{JobStatusChanged}} message, it will look up the
{{ExecutionGraph}} for the given {{JobID}}. If there is no {{ExecutionGraph}}, then a {{RemoveJob}}
message is sent to itself. In the general case, this is not problematic, because the {{RemoveJob}}
message won't do anything if there is no {{ExecutionGraph}}. However, since this is an asynchronous
call, it can happen that the corresponding job of the {{JobID}} is recovered before receiving
the {{RemoveJob}} message. In this case, the newly recovered job would be removed.
> I propose to change the behaviour such that a {{JobStatusChanged}} for a non-existing
{{ExecutionGraph}} will be simply ignored.

This message was sent by Atlassian JIRA

View raw message