You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2016/12/23 20:22:50 UTC
[31/52] [abbrv] flink git commit: [FLINK-5171] [runtime] fix wrong
use of Preconditions.checkState in TaskManagerRunner
[FLINK-5171] [runtime] fix wrong use of Preconditions.checkState in TaskManagerRunner
This closes #2880.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b58c6dcb
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b58c6dcb
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b58c6dcb
Branch: refs/heads/master
Commit: b58c6dcb820b7434fbec206820c57845c06d84d6
Parents: 006a19d
Author: shuai.xus <sh...@alibaba-inc.com>
Authored: Mon Nov 28 17:21:26 2016 +0800
Committer: Stephan Ewen <se...@apache.org>
Committed: Fri Dec 23 20:54:25 2016 +0100
----------------------------------------------------------------------
.../org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/b58c6dcb/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java
index 99a7c5d..a18ff40 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java
@@ -185,7 +185,7 @@ public class TaskManagerRunner implements FatalErrorHandler {
final int rpcPort = configuration.getInteger(ConfigConstants.TASK_MANAGER_IPC_PORT_KEY, 0);
- Preconditions.checkState(rpcPort < 0 || rpcPort >65535, "Invalid value for " +
+ Preconditions.checkState(rpcPort >= 0 && rpcPort <= 65535, "Invalid value for " +
"'%s' (port for the TaskManager actor system) : %d - Leave config parameter empty or " +
"use 0 to let the system choose port automatically.",
ConfigConstants.TASK_MANAGER_IPC_PORT_KEY, rpcPort);