This is an automated email from the ASF dual-hosted git repository.
RocMarshal 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 086324464df [hotfix][core] Update the default duration value setting
coding on 'taskmanager.registration.timeout'.
086324464df is described below
commit 086324464df8363f5418e5e80e598e27ffbe0c3c
Author: Yuepeng Pan <[email protected]>
AuthorDate: Sun Sep 27 00:20:34 2026 +0800
[hotfix][core] Update the default duration value setting coding on
'taskmanager.registration.timeout'.
---
.../main/java/org/apache/flink/configuration/TaskManagerOptions.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git
a/flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java
b/flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java
index 0244a898fe8..378682431c0 100644
---
a/flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java
+++
b/flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java
@@ -23,7 +23,6 @@ import org.apache.flink.annotation.docs.ConfigGroup;
import org.apache.flink.annotation.docs.ConfigGroups;
import org.apache.flink.annotation.docs.Documentation;
import org.apache.flink.configuration.description.Description;
-import org.apache.flink.util.TimeUtils;
import java.time.Duration;
import java.util.HashMap;
@@ -138,7 +137,7 @@ public class TaskManagerOptions {
public static final ConfigOption<Duration> REGISTRATION_TIMEOUT =
key("taskmanager.registration.timeout")
.durationType()
- .defaultValue(TimeUtils.parseDuration("5 min"))
+ .defaultValue(Duration.ofMinutes(5L))
.withDeprecatedKeys("taskmanager.maxRegistrationDuration")
.withDescription(
"Defines the timeout for the TaskManager
registration. If the duration is"