This is an automated email from the ASF dual-hosted git repository.
junrui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new f2cf6f71e9b [hotfix] [docs] Fix code typo in task_failure_recovery.md
f2cf6f71e9b is described below
commit f2cf6f71e9bb365614f79b6eef7ed8cd6ca59bcc
Author: glorinli <ligr1...@gmail.com>
AuthorDate: Fri Jan 24 09:47:20 2025 +0800
[hotfix] [docs] Fix code typo in task_failure_recovery.md
---
docs/content/docs/ops/state/task_failure_recovery.md | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/docs/content/docs/ops/state/task_failure_recovery.md
b/docs/content/docs/ops/state/task_failure_recovery.md
index cb16172beb3..a30cb261725 100644
--- a/docs/content/docs/ops/state/task_failure_recovery.md
+++ b/docs/content/docs/ops/state/task_failure_recovery.md
@@ -176,10 +176,10 @@ The exponential delay restart strategy can also be set
programmatically:
```java
Configuration config = new Configuration();
config.set(RestartStrategyOptions.RESTART_STRATEGY, "exponential-delay");
-config.set(RestartStrategyOptions.RESTART_STRATEGY_EXPONENTIAL_DELAY_INITIAL_BACKOFF,
Durartion.ofMillis(1));
-config.set(RestartStrategyOptions.RESTART_STRATEGY_EXPONENTIAL_DELAY_MAX_BACKOFF,
Durartion.ofMillis(1000));
+config.set(RestartStrategyOptions.RESTART_STRATEGY_EXPONENTIAL_DELAY_INITIAL_BACKOFF,
Duration.ofMillis(1));
+config.set(RestartStrategyOptions.RESTART_STRATEGY_EXPONENTIAL_DELAY_MAX_BACKOFF,
Duration.ofMillis(1000));
config.set(RestartStrategyOptions.RESTART_STRATEGY_EXPONENTIAL_DELAY_BACKOFF_MULTIPLIER,
1.1); // exponential multiplier
-config.set(RestartStrategyOptions.RESTART_STRATEGY_EXPONENTIAL_DELAY_RESET_BACKOFF_THRESHOLD,
Durartion.ofMillis(2000)); // threshold duration to reset delay to its initial
value
+config.set(RestartStrategyOptions.RESTART_STRATEGY_EXPONENTIAL_DELAY_RESET_BACKOFF_THRESHOLD,
Duration.ofMillis(2000)); // threshold duration to reset delay to its initial
value
config.set(RestartStrategyOptions.RESTART_STRATEGY_EXPONENTIAL_DELAY_JITTER_FACTOR,
0.1); // jitter
StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment(config);
```
