[flink] branch release-1.8 updated: [FLINK-12009][runtime] Fix wrong check message about heartbeat interval for HeartbeatServices This closes #8048.

[ji...@apache.org]

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

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


The following commit(s) were added to refs/heads/release-1.8 by this push:
     new 03d0a39  [FLINK-12009][runtime] Fix wrong check message about heartbeat interval for HeartbeatServices This closes #8048.
03d0a39 is described below

commit 03d0a398e3402e7566c1a396586e7fff9414e2e9
Author: yanghua <ya...@gmail.com>
AuthorDate: Tue Mar 26 14:09:26 2019 +0800

    [FLINK-12009][runtime] Fix wrong check message about heartbeat interval for HeartbeatServices
    This closes #8048.
---
 .../main/java/org/apache/flink/runtime/heartbeat/HeartbeatServices.java | 2 +-
 1 file changed, 1 insertion(+), 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
index 22df751..d87f7a8 100644
--- 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;