Rui Fan created FLINK-33865:
-------------------------------
Summary: 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
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)
