You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/04/13 20:18:39 UTC
flink git commit: [FLINK-9103] Using CanonicalHostName instead of IP
for SSL coonection on NettyClient
Repository: flink
Updated Branches:
refs/heads/release-1.4 bfe3ad5fe -> e76b10d07
[FLINK-9103] Using CanonicalHostName instead of IP for SSL coonection on NettyClient
This closes #5789.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e76b10d0
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e76b10d0
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e76b10d0
Branch: refs/heads/release-1.4
Commit: e76b10d07c657bcf3250ca08b5649c6a242bb01f
Parents: bfe3ad5
Author: EAlexRojas <al...@gmail.com>
Authored: Thu Mar 29 16:01:24 2018 +0200
Committer: Till Rohrmann <tr...@apache.org>
Committed: Fri Apr 13 13:18:26 2018 -0700
----------------------------------------------------------------------
.../org/apache/flink/runtime/io/network/netty/NettyClient.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/e76b10d0/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyClient.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyClient.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyClient.java
index c845cb3..5fb083d 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyClient.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyClient.java
@@ -179,7 +179,7 @@ class NettyClient {
// SSL handler should be added first in the pipeline
if (clientSSLContext != null) {
SSLEngine sslEngine = clientSSLContext.createSSLEngine(
- serverSocketAddress.getAddress().getHostAddress(),
+ serverSocketAddress.getAddress().getCanonicalHostName(),
serverSocketAddress.getPort());
sslEngine.setUseClientMode(true);