[SPARK-35482][K8S] Use spark.blockManager.port not wrong spark.blockmanger.port

yaooqinn · yaooqinn · commit 2dcb524fe700 · 2021-05-21T20:57:24.000+08:00
diff --git a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/features/BasicExecutorFeatureStep.scala b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/features/BasicExecutorFeatureStep.scala
@@ -175,7 +175,7 @@ private[spark] class BasicExecutorFeatureStep(
         .replaceAll(ENV_EXECUTOR_ID, kubernetesConf.executorId))
     }
 
-    // 0 is invalid as kubernetes contain port request, we shall leave it
+    // 0 is invalid as kubernetes containerPort request, we shall leave it unmounted
     val requiredPorts = if (blockManagerPort != 0) {
       Seq(
         (BLOCK_MANAGER_PORT_NAME, blockManagerPort))

Original file line number	Diff line number	Diff line change
`@@ -175,7 +175,7 @@ private[spark] class BasicExecutorFeatureStep(`
`175`	`175`	`.replaceAll(ENV_EXECUTOR_ID, kubernetesConf.executorId))`
`176`	`176`	`}`
`177`	`177`
`178`		`- // 0 is invalid as kubernetes contain port request, we shall leave it`
	`178`	`+ // 0 is invalid as kubernetes containerPort request, we shall leave it unmounted`
`179`	`179`	`val requiredPorts = if (blockManagerPort != 0) {`
`180`	`180`	`Seq(`
`181`	`181`	`(BLOCK_MANAGER_PORT_NAME, blockManagerPort))`