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 2019/11/08 08:24:22 UTC
[flink] 02/02: [FLINK-14481][runtime] Change Flink's port check to
0 to 65535
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 0b3372605cf46aed72dbe926fa8f10d4511147b9
Author: joe <15...@163.com>
AuthorDate: Fri Oct 25 11:02:44 2019 +0800
[FLINK-14481][runtime] Change Flink's port check to 0 to 65535
This closes #9992
---
.../java/org/apache/flink/runtime/io/network/netty/NettyConfig.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyConfig.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyConfig.java
index 9730907..7a42f67 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyConfig.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyConfig.java
@@ -63,7 +63,7 @@ public class NettyConfig {
this.serverAddress = checkNotNull(serverAddress);
- checkArgument(serverPort >= 0 && serverPort <= 65536, "Invalid port number.");
+ checkArgument(serverPort >= 0 && serverPort <= 65535, "Invalid port number.");
this.serverPort = serverPort;
checkArgument(memorySegmentSize > 0, "Invalid memory segment size.");