Skip to content

[SPARK-25922][K8] Spark Driver/Executor "spark-app-selector" label mismatch #23322

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
suxingfate wants to merge 10 commits into from
Closed

[SPARK-25922][K8] Spark Driver/Executor "spark-app-selector" label mismatch #23322

Changes from 1 commit
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
89c438c
[SPARK-25922][K8] Spark Driver/Executor spark-app-selector label mism…
Dec 14, 2018
ed2c4ca
Simplify the logic to use spark.app.id if set otherwise use superclas…
suxingfate Dec 15, 2018
fa45013
Merge branch 'master' into SPARK-25922
suxingfate Dec 15, 2018
5ed8e1a
remove unnessesary KubernetesUtils import in KubernetesClusterSchedul…
suxingfate Dec 15, 2018
db3fceb
remove unnessesary UUID import in KubernetesUtils.scala
suxingfate Dec 15, 2018
af73427
refactor applicationId to be neat as one line
suxingfate Dec 15, 2018
778acb4
add unit testing to test applicationId in case spark.app.id is set
suxingfate Dec 15, 2018
bf4bc0e
update style for getOrElse
suxingfate Dec 15, 2018
8844f3d
Merge branch 'master' into SPARK-25922
suxingfate Dec 15, 2018
45ded64
run ./dev/scalafmt to reformat
suxingfate Dec 15, 2018
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
remove unnessesary UUID import in KubernetesUtils.scala
  • Loading branch information
@suxingfate
suxingfate committed Dec 15, 2018
commit db3fcebd25b803e7b4358201997ecc3f995642b1
3 changes: 2 additions & 1 deletion ...managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/KubernetesUtils.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,11 +17,12 @@
package org.apache.spark.deploy.k8s

import java.io.File
import java.util.UUID

import scala.collection.JavaConverters._

import io.fabric8.kubernetes.api.model.{Container, ContainerBuilder, ContainerStateRunning, ContainerStateTerminated, ContainerStateWaiting, ContainerStatus, Pod, PodBuilder}
import io.fabric8.kubernetes.client.KubernetesClient

import org.apache.spark.{SparkConf, SparkException}
import org.apache.spark.internal.Logging
import org.apache.spark.util.Utils
Expand Down