Skip to content

Commit

Permalink
[SPARK-48121][K8S] Promote KubernetesDriverConf to DeveloperApi
Browse files Browse the repository at this point in the history
### What changes were proposed in this pull request?

This PR aims to promote `KubernetesDriverConf` to `DeveloperApi`

### Why are the changes needed?

Since Apache Spark Kubernetes Operator requires this, we had better maintain it as a developer API officially from Apache Spark 4.0.0.

apache/spark-kubernetes-operator#10

### Does this PR introduce _any_ user-facing change?

No

### How was this patch tested?

Pass the CIs

### Was this patch authored or co-authored using generative AI tooling?

No

Closes apache#46373 from jiangzho/driver_conf.

Authored-by: zhou-jiang <zhou_jiang@apple.com>
Signed-off-by: Dongjoon Hyun <dhyun@apple.com>
  • Loading branch information
jiangzho authored and dongjoon-hyun committed May 3, 2024
1 parent b42d235 commit c3a462c
Showing 1 changed file with 10 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@ import io.fabric8.kubernetes.api.model.{LocalObjectReference, LocalObjectReferen
import org.apache.commons.lang3.StringUtils

import org.apache.spark.{SPARK_VERSION, SparkConf}
import org.apache.spark.annotation.{DeveloperApi, Since, Unstable}
import org.apache.spark.deploy.k8s.Config._
import org.apache.spark.deploy.k8s.Constants._
import org.apache.spark.deploy.k8s.features.DriverServiceFeatureStep._
Expand Down Expand Up @@ -78,7 +79,15 @@ private[spark] abstract class KubernetesConf(val sparkConf: SparkConf) {
def getOption(key: String): Option[String] = sparkConf.getOption(key)
}

private[spark] class KubernetesDriverConf(
/**
* :: DeveloperApi ::
*
* Used for K8s operations internally and Spark K8s operator.
*/
@Unstable
@DeveloperApi
@Since("4.0.0")
class KubernetesDriverConf(
sparkConf: SparkConf,
val appId: String,
val mainAppResource: MainAppResource,
Expand Down

0 comments on commit c3a462c

Please sign in to comment.