apache/celeborn
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Correct environment variable RSS_LOCAL_IP (#618)

Browse Source
This commit is contained in:
Cheng Pan 2022-09-19 14:54:49 +08:00 committed by GitHub
parent e48efb2e1c
commit 618da0c70d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
common/src/main/scala/com/aliyun/emr/rss/common/util/Utils.scala
View File

@ -319,7 +319,7 @@ object Utils extends Logging {
private lazy val localIpAddress: InetAddress = findLocalInetAddress()
private def findLocalInetAddress(): InetAddress = {
val defaultIpOverride = System.getenv("JSS_LOCAL_IP")
val defaultIpOverride = System.getenv("RSS_LOCAL_IP")
if (defaultIpOverride != null) {
InetAddress.getByName(defaultIpOverride)
} else {
@ -344,14 +344,14 @@ object Utils extends Logging {
logWarning("Your hostname, " + InetAddress.getLocalHost.getHostName + " resolves to" +
" a loopback address: " + address.getHostAddress + "; using " +
strippedAddress.getHostAddress + " instead (on interface " + ni.getName + ")")
logWarning("Set JSS_LOCAL_IP if you need to bind to another address")
logWarning("Set RSS_LOCAL_IP if you need to bind to another address")
return strippedAddress
}
}
logWarning("Your hostname, " + InetAddress.getLocalHost.getHostName + " resolves to" +
" a loopback address: " + address.getHostAddress + ", but we couldn't find any" +
" external IP address!")
logWarning("Set JSS_LOCAL_IP if you need to bind to another address")
logWarning("Set RSS_LOCAL_IP if you need to bind to another address")
}
address
}