Github user mccheah commented on a diff in the pull request:
https://github.com/apache/spark/pull/20910#discussion_r177265297
--- Diff:
resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/KubernetesSpec.scala
---
@@ -14,25 +14,18 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.spark.deploy.k8s.submit.steps
+package org.apache.spark.deploy.k8s
-import org.apache.spark.deploy.k8s.MountSecretsBootstrap
-import org.apache.spark.deploy.k8s.submit.KubernetesDriverSpec
+import io.fabric8.kubernetes.api.model.HasMetadata
-/**
- * A driver configuration step for mounting user-specified secrets onto
user-specified paths.
- *
- * @param bootstrap a utility actually handling mounting of the secrets.
- */
-private[spark] class DriverMountSecretsStep(
- bootstrap: MountSecretsBootstrap) extends DriverConfigurationStep {
+private[k8s] case class KubernetesSpec(
+ pod: SparkPod,
+ additionalDriverKubernetesResources: Seq[HasMetadata],
+ podJavaSystemProperties: Map[String, String])
- override def configureDriver(driverSpec: KubernetesDriverSpec):
KubernetesDriverSpec = {
- val pod = bootstrap.addSecretVolumes(driverSpec.driverPod)
- val container = bootstrap.mountSecrets(driverSpec.driverContainer)
- driverSpec.copy(
- driverPod = pod,
- driverContainer = container
- )
- }
+private[k8s] object KubernetesSpec {
--- End diff --
Probably should just be `private[spark]`
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
