[tests] Fix hostname escaping for older akka versions.

743399a4 · Stephan Ewen · 5ab1f1f1 · 743399a4
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala .../main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala +1 -1

未找到文件。
--- a/flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala
+++ b/flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala
@@ -97,7 +97,7 @@ object AkkaUtils {
    listeningAddress match {

      case Some((hostname, port)) =>
-        val ipAddress = InetAddress.getByName(hostname).getHostAddress()
+        val ipAddress = "\"" + InetAddress.getByName(hostname).getHostAddress() + "\""
        val remoteConfig = getRemoteAkkaConfig(configuration, ipAddress, port)
        remoteConfig.withFallback(defaultConfig)