Repository: flink Updated Branches: refs/heads/master 5ab1f1f19 -> 743399a41
[tests] Fix hostname escaping for older akka versions. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/743399a4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/743399a4 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/743399a4 Branch: refs/heads/master Commit: 743399a41c0c52a04d472110e7c3b4b32bbf9733 Parents: 5ab1f1f Author: Stephan Ewen <se...@apache.org> Authored: Mon Feb 16 21:50:34 2015 +0100 Committer: Stephan Ewen <se...@apache.org> Committed: Mon Feb 16 21:50:34 2015 +0100 ---------------------------------------------------------------------- .../src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/743399a4/flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala ---------------------------------------------------------------------- diff --git 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 index 5a1a2be..f6062ca 100644 --- 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)
