Github user heary-cao commented on a diff in the pull request:
https://github.com/apache/spark/pull/18555#discussion_r166164325
--- Diff:
core/src/main/scala/org/apache/spark/internal/config/package.scala ---
@@ -231,6 +315,9 @@ package object config {
private[spark] val BLOCK_MANAGER_PORT =
ConfigBuilder("spark.blockManager.port")
.doc("Port to use for the block manager when a more specific setting
is not provided.")
.intConf
+ .checkValue(v => v == 0 || (1024 <= v && v < 65536),
--- End diff --
@jerryshao , @HyukjinKwon
Because of the same port control at startServiceOnPort, do we need to open
it here?
def startServiceOnPort[T](
startPort: Int,
startService: Int => (T, Int),
conf: SparkConf,
serviceName: String = ""): (T, Int) = {
require(startPort == 0 || (1024 <= startPort && startPort < 65536),
"startPort should be between 1024 and 65535 (inclusive), or 0 for a
random free port.")
...
}
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
