[
https://issues.apache.org/jira/browse/FLINK-4299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4299.
------------------------------
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in 4d988a9 (release-1.1), 7ea9c01 (master).
> Show loss of job manager in Client
> ----------------------------------
>
> Key: FLINK-4299
> URL: https://issues.apache.org/jira/browse/FLINK-4299
> Project: Flink
> Issue Type: Improvement
> Components: Client
> Reporter: Ufuk Celebi
> Assignee: Maximilian Michels
> Fix For: 1.1.0, 1.2.0
>
>
> If the client looses the connection to a job manager and the job recovers
> from this, the client will only print the job status as {{RUNNING}} again. It
> is hard to actually notice that something went wrong and a job manager was
> lost.
> {code}
> ...
> 08/01/2016 14:35:43 Flat Map -> Sink: Unnamed(8/8) switched to RUNNING
> 08/01/2016 14:35:43 Source: Custom Source(6/8) switched to RUNNING
> <------ EVERYTHING'S RUNNING ------>
> 08/01/2016 14:40:40 Job execution switched to status RUNNING <--- JOB
> MANAGER FAIL OVER
> 08/01/2016 14:40:40 Source: Custom Source(1/8) switched to SCHEDULED
> 08/01/2016 14:40:40 Source: Custom Source(1/8) switched to DEPLOYING
> 08/01/2016 14:40:40 Source: Custom Source(2/8) switched to SCHEDULED
> ...
> {code}
> After {{14:35:43}} everything is running and the client does not print any
> execution state updates. When the job manager fails, the job will be
> recovered and enter the running state again eventually (at 14:40:40), but the
> user might never notice this.
> I would like to improve on this by printing some messages about the state of
> the job manager connection. For example, between {{14:35:43}} and
> {{14:40:40}} it might say that the job manager connection was lost, a new one
> established, etc.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
