You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2016/12/23 20:22:41 UTC
[22/52] [abbrv] flink git commit: [FLINK-5170] [akka] Fix hostname
usage in AkkaUtils.getConfig
[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 <sh...@alibaba-inc.com>
Authored: Mon Nov 28 17:14:35 2016 +0800
Committer: Stephan Ewen <se...@apache.org>
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)
}
/**