zhuzhurk commented on code in PR #23247:
URL: https://github.com/apache/flink/pull/23247#discussion_r1423639034
##########
flink-core/src/main/java/org/apache/flink/configuration/RestartStrategyOptions.java:
##########
@@ -222,6 +223,19 @@ public class RestartStrategyOptions {
code(RESTART_STRATEGY.key()),
code("exponential-delay"))
.build());
+ @Documentation.OverrideDefault("infinite")
+ public static final ConfigOption<Integer>
RESTART_STRATEGY_EXPONENTIAL_DELAY_ATTEMPTS =
+
ConfigOptions.key("restart-strategy.exponential-delay.attempts-before-reset-backoff")
+ .intType()
+ .defaultValue(Integer.MAX_VALUE)
+ .withDescription(
+ Description.builder()
+ .text(
+ "The number of times that Flink
retries the execution before the job is declared as failed "
+ + "before resetting the
backoff to its initial value if %s has been set to %s.",
Review Comment:
Maybe separate the long statement to make it easier for reading? e.g.
```
The number of times that Flink retries the execution before failing the job
if %s has been set to %s. The number will be reset once the backoff is reset to
its initial value.
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
