Github user mccheah commented on a diff in the pull request:
https://github.com/apache/spark/pull/21092#discussion_r190980379
--- Diff:
resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/KubernetesConf.scala
---
@@ -63,10 +67,16 @@ private[spark] case class KubernetesConf[T <:
KubernetesRoleSpecificConf](
.map(str => str.split(",").toSeq)
.getOrElse(Seq.empty[String])
- def sparkFiles(): Seq[String] = sparkConf
- .getOption("spark.files")
- .map(str => str.split(",").toSeq)
- .getOrElse(Seq.empty[String])
+ def getRoleConf: T = roleSpecificConf
--- End diff --
Don't think we use this anywhere?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
