[jira] [Commented] (FLINK-10572) Enable Per-job level failover strategy.

["ASF GitHub Bot (JIRA)" <ji...@apache.org>]

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

ASF GitHub Bot commented on FLINK-10572:
----------------------------------------

isunjin opened a new pull request #6901: [FLINK-10572] [JobManager] Enable Per-Job level failover config
URL: https://github.com/apache/flink/pull/6901
 
 
   ## What is the purpose of the change
   
   *Today we Failover strategy is a cluster level config, we cannot set it for individual job, this PR try to expose the config to ExecutionConfig and let it can be set in per-job level*
   
   
   ## Brief change log
   
     - *Add enum FailoverStrategyType*
     - *Add set FailoverStrategyType in ExecutionConfig*
     - *Extract FailoverStrategyType and pass it to ExecutionGraph*
   
   
   ## Verifying this change
   
   This change added tests and can be verified as follows:
     - *A test in jobMaster to validate the config was passed correctly.*
   
   ## Does this pull request potentially affect one of the following parts:
   
     - The public API, i.e., is any changed class annotated with `@Public(Evolving)`:  yes
   
   ## Documentation
     - If yes, how is the feature documented? (not documented, will be handled in [FLINK-10574](https://issues.apache.org/jira/browse/FLINK-10574)
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


> Enable Per-job level failover strategy. 
> ----------------------------------------
>
>                 Key: FLINK-10572
>                 URL: https://issues.apache.org/jira/browse/FLINK-10572
>             Project: Flink
>          Issue Type: Sub-task
>          Components: JobManager
>            Reporter: JIN SUN
>            Assignee: JIN SUN
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.7.0
>
>
> Today we can specify ExecutionMode in ExecutionConfig, its a per-job setting. However,  FailoverStrategy is a cluster-level configuration, while it should be per-job:
>  * The FailoverStrategy has dependencies with ExecutionMode in ExecutionConfig, such as Pipelined ExecutionMode doesn't compatible with RestartIndividualStrategy, so set it as cluster-level doesn't make sense.
>  *  The FailoverStrategy also has dependencies with RestartStrategy. Like in the new Batch failover strategy, instead of keep on restarting, we want to fail the job if certain condition met, as a result, a NoRestart or some new Restart strategy should be configured. 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)