[FLINK-9103] Using CanonicalHostName instead of IP for SSL coonection…

… on NettyClient This closes apache#5789.
deepfield · Apr 13, 2018 · ffb0382 · ffb0382
1 parent 7a78d00
commit ffb0382
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -179,7 +179,7 @@ public void initChannel(SocketChannel channel) throws Exception {
  // 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);