Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4774#discussion_r147743853
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala ---
@@ -257,6 +257,20 @@ object AkkaUtils {
ConfigFactory.parseString(config)
}
+ private def validateHeartbeat(pauseParamName: String,
+ pauseValue: String,
+ intervalParamName: String,
+ intervalValue: String) = {
+ if (Duration.apply(pauseValue).lteq(Duration.apply(intervalValue))) {
+ throw new IllegalConfigurationException(
+ "%s [%s] must greater then %s [%s]",
--- End diff --
this should actually be "than", not "then"
---
