flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ufuk Celebi (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-2804) Support blocking job submission with Job Manager recovery
Date Fri, 02 Oct 2015 09:56:26 GMT
Ufuk Celebi created FLINK-2804:

             Summary: Support blocking job submission with Job Manager recovery
                 Key: FLINK-2804
                 URL: https://issues.apache.org/jira/browse/FLINK-2804
             Project: Flink
          Issue Type: Improvement
    Affects Versions: master
            Reporter: Ufuk Celebi
            Assignee: Ufuk Celebi
            Priority: Minor

Submitting a job in a blocking fashion with JobManager recovery and a failing JobManager fails
on the client side (the one submitting the job). The job still continues to be recovered.

I propose to add simple support to re-retrieve the leading job manager and update the client
actor with it and then wait for the result as before.

As of the current standing in PR #1153 (https://github.com/apache/flink/pull/1153) the job
manager assumes that the same actor is running and just keeps on sending execution state updates
etc. (if the listening behaviour is not detached).

This message was sent by Atlassian JIRA

View raw message