[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/8265b545 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8265b545 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8265b545 Branch: refs/heads/flip-6 Commit: 8265b545cff2fb5e6ca3771effd46a2fda488576 Parents: 09ec78a Author: shuai.xus <[email protected]> Authored: Mon Nov 28 17:14:35 2016 +0800 Committer: Till Rohrmann <[email protected]> Committed: Mon Nov 28 17:11:29 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/8265b545/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 9ac9773..ddb9fc3 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) } /**
