[SPARK-36832] Add LauncherProtocol to K8s resource manager client

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 3.1.2
• Component/s: Spark Submit
• Assignee: Unassigned
• Reporter: timothy65535
• Created: 23/Sep/21 12:16
• Updated: 26/Sep/21 03:52

Description

Refer to: org.apache.spark.deploy.yarn.Client

private val launcherBackend = new LauncherBackend() {
  override protected def conf: SparkConf = sparkConf  override def onStopRequest(): Unit = {
    if (isClusterMode && appId != null) {
      yarnClient.killApplication(appId)
    } else {
      setState(SparkAppHandle.State.KILLED)
      stop()
    }
  }
}