[FLINK-5170] [akka] Fix hostname usage in AkkaUtils.getConfig This closes #2879.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9ad9fa95 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9ad9fa95 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/9ad9fa95 Branch: refs/heads/master Commit: 9ad9fa95ed0485a985250d2735c86154009fd515 Parents: b58c6dc Author: shuai.xus <[email protected]> Authored: Mon Nov 28 17:14:35 2016 +0800 Committer: Stephan Ewen <[email protected]> Committed: Fri Dec 23 20:54:25 2016 +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/9ad9fa95/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 b25e29e..4fe39b6 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 @@ -115,7 +115,7 @@ object AkkaUtils { } def getAkkaConfig(configuration: Configuration, hostname: String, port: Int): Config = { - getAkkaConfig(configuration, if (hostname == null) Some((hostname, port)) else None) + getAkkaConfig(configuration, if (hostname != null) Some((hostname, port)) else None) } /**
