[flink] branch release-1.5 updated: [FLINK-9546] Fix checking of heartbeatTimeoutIntervalMs in HeartbeatMonitor

[trohrmann]

This is an automated email from the ASF dual-hosted git repository.

trohrmann pushed a commit to branch release-1.5
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.5 by this push:
     new 1e450f4  [FLINK-9546] Fix checking of heartbeatTimeoutIntervalMs in 
HeartbeatMonitor
1e450f4 is described below

commit 1e450f435d010c996c32b2b370957477dd6f37b9
Author: sihuazhou <summerle...@163.com>
AuthorDate: Thu Jun 7 16:26:20 2018 +0800

    [FLINK-9546] Fix checking of heartbeatTimeoutIntervalMs in HeartbeatMonitor
    
    This closes #6135.
---
 .../java/org/apache/flink/runtime/heartbeat/HeartbeatManagerImpl.java   | 2 +-
 1 file changed, 1 insertion(+), 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
index 42268fc..242fbaa 100644
--- 
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 @@ public class HeartbeatManagerImpl<I, O> implements 
HeartbeatManager<I, O> {
                        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;