Skip to content

Commit c565c9f

Browse files
committed
Couple of more style comments
1 parent c052212 commit c565c9f

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

resource-managers/kubernetes/core/src/main/scala/org/apache/spark/scheduler/cluster/k8s/KubernetesClusterSchedulerBackend.scala

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -62,8 +62,7 @@ private[spark] class KubernetesClusterSchedulerBackend(
6262

6363
private val kubernetesDriverPodName = conf
6464
.get(KUBERNETES_DRIVER_POD_NAME)
65-
.getOrElse(
66-
throw new SparkException("Must specify the driver pod name"))
65+
.getOrElse(throw new SparkException("Must specify the driver pod name"))
6766
private implicit val requestExecutorContext = ExecutionContext.fromExecutorService(
6867
requestExecutorsService)
6968

@@ -86,7 +85,7 @@ private[spark] class KubernetesClusterSchedulerBackend(
8685
}
8786

8887
private val executorWatchResource = new AtomicReference[Closeable]
89-
protected var totalExpectedExecutors = new AtomicInteger(0)
88+
protected val totalExpectedExecutors = new AtomicInteger(0)
9089

9190
private val driverUrl = RpcEndpointAddress(
9291
conf.get("spark.driver.host"),

0 commit comments

Comments
 (0)