Marios Trivyzas created FLINK-26007:
---------------------------------------
Summary: Use durationType instead of stringType for time related
config options
Key: FLINK-26007
URL: https://issues.apache.org/jira/browse/FLINK-26007
Project: Flink
Issue Type: Improvement
Reporter: Marios Trivyzas
Check and change all relevant config options so that we have a well
typed/defined type instead of parsing a string.
*NOTE:* This is a breaking change!
e.g.:
{noformat}
AkkaOptions#WATCH_HEARTBEAT_PAUSE
public static final ConfigOption<String> WATCH_HEARTBEAT_PAUSE =
ConfigOptions.key("akka.watch.heartbeat.pause")
.defaultValue("60 s")
.withDescription(
Description.builder()
.text(
"Acceptable heartbeat pause for Akka’s
DeathWatch mechanism. A low value does not allow an"
+ " irregular heartbeat. If
TaskManagers are wrongly marked dead because of lost or delayed"
+ " heartbeat messages, then you
should increase this value or decrease akka.watch.heartbeat.interval."
+ " Higher value increases the time
to detect a dead TaskManager. A thorough description of Akka’s"
+ " DeathWatch can be found %s",
link(
"http://doc.akka.io/docs/akka/snapshot/scala/remoting.html#failure-detector";,
"here"))
.build());{noformat}
https://github.com/apache/flink/blob/master/flink-core/src/main/java/org/apache/flink/configuration/AkkaOptions.java#L300
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
