[ 
https://issues.apache.org/jira/browse/FLINK-33865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

ASF GitHub Bot updated FLINK-33865:
-----------------------------------
    Labels: pull-request-available  (was: )

> exponential-delay.attempts-before-reset-backoff doesn't work when it's set in 
> Job Configuration
> -----------------------------------------------------------------------------------------------
>
>                 Key: FLINK-33865
>                 URL: https://issues.apache.org/jira/browse/FLINK-33865
>             Project: Flink
>          Issue Type: Bug
>          Components: Runtime / Coordination
>            Reporter: Rui Fan
>            Assignee: Rui Fan
>            Priority: Major
>              Labels: pull-request-available
>         Attachments: image-2023-12-17-17-56-59-138.png
>
>
> exponential-delay.attempts-before-reset-backoff doesn't work when it's set in 
> Job Configuration.
> Reason: when exponential-delay.attempts-before-reset-backoff is set by job 
> Configuration instead of cluster configuration.
> ExecutionConfig#configure will call RestartStrategies#parseConfiguration to 
> create the RestartStrategyConfiguration. And then 
> RestartBackoffTimeStrategyFactoryLoader#getJobRestartStrategyFactory will 
> create the ExponentialDelayRestartBackoffTimeStrategyFactory by the 
> RestartStrategyConfiguration.
> Since 1.19, RestartStrategies and RestartStrategyConfiguration are depreated, 
> so it doesn't support exponential-delay.attempts-before-reset-backoff.
> I have a misunderstand during FLINK-32895, I thought the 
> RestartBackoffTimeStrategyFactoryLoader#createRestartBackoffTimeStrategyFactory
>  will create ExponentialDelayRestartBackoffTimeStrategyFactory by the 
> clusterConfiguration.
>  !image-2023-12-17-17-56-59-138.png! 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to