[FLINK-9546] Fix checking of heartbeatTimeoutIntervalMs in HeartbeatM…

…onitor This closes apache#6135.
static-max · Aug 15, 2018 · 7d4fcae · 7d4fcae
1 parent 020f329
commit 7d4fcae
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatManagerImpl.java b/flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatManagerImpl.java
@@ -277,7 +277,7 @@ static class HeartbeatMonitor<O> implements Runnable {
  this.scheduledExecutor = Preconditions.checkNotNull(scheduledExecutor);
  this.heartbeatListener = Preconditions.checkNotNull(heartbeatListener);
 
- Preconditions.checkArgument(heartbeatTimeoutIntervalMs >= 0L, "The heartbeat timeout interval has to be larger than 0.");
+ Preconditions.checkArgument(heartbeatTimeoutIntervalMs > 0L, "The heartbeat timeout interval has to be larger than 0.");
  this.heartbeatTimeoutIntervalMs = heartbeatTimeoutIntervalMs;
 
  lastHeartbeat = 0L;