[FLINK-12009][runtime] Fix wrong check message about heartbeat interv…

…al for HeartbeatServices This closes apache#8048.
deepfield · Apr 9, 2019 · dca64c2 · dca64c2
1 parent 7236c75
commit dca64c2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatServices.java b/flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatServices.java
@@ -40,7 +40,7 @@ public class HeartbeatServices {
 
  public HeartbeatServices(long heartbeatInterval, long heartbeatTimeout) {
  Preconditions.checkArgument(0L < heartbeatInterval, "The heartbeat interval must be larger than 0.");
- Preconditions.checkArgument(heartbeatInterval <= heartbeatTimeout, "The heartbeat timeout should be larger or equal than the heartbeat timeout.");
+ Preconditions.checkArgument(heartbeatInterval <= heartbeatTimeout, "The heartbeat timeout should be larger or equal than the heartbeat interval.");
 
  this.heartbeatInterval = heartbeatInterval;
  this.heartbeatTimeout = heartbeatTimeout;