Repository: flink
Updated Branches:
  refs/heads/release-1.5 471087a3e -> 688630c64


[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/688630c6
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/688630c6
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/688630c6

Branch: refs/heads/release-1.5
Commit: 688630c6432dd3318936613a3f657f7de475fce7
Parents: 98e246b
Author: EAlexRojas <alexrojas...@gmail.com>
Authored: Thu Mar 29 16:01:24 2018 +0200
Committer: Till Rohrmann <trohrm...@apache.org>
Committed: Fri Apr 13 13:16:07 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/688630c6/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);
 

Reply via email to