Skip to content

Commit a253c9a

Browse files
committed
small fixups
1 parent c5d0b9d commit a253c9a

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

core/pom.xml

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -365,7 +365,6 @@
365365
<artifactId>spark-tags_${scala.binary.version}</artifactId>
366366
</dependency>
367367

368-
369368
<dependency>
370369
<groupId>org.apache.spark</groupId>
371370
<artifactId>spark-launcher_${scala.binary.version}</artifactId>

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -118,7 +118,7 @@ private[spark] class ExecutorPodsAllocator(
118118
}
119119
val currentTotalExpectedExecutors = totalExpectedExecutors.get
120120
safeLogDebug("Currently have running executors and" +
121-
" pending executors. Newly created executors executors" +
121+
" pending executors. Newly created executors" +
122122
" have been requested but are pending appearance in the cluster.",
123123
SafeArg.of("numCurrentRunningExecutors", currentRunningExecutors),
124124
SafeArg.of("numCurrentPendingExecutors", currentPendingExecutors),
@@ -157,7 +157,7 @@ private[spark] class ExecutorPodsAllocator(
157157
" executors to begin running before requesting for more executors, including executors" +
158158
" in pending status in the cluster, and executors that we have" +
159159
" created but we have not observed as being present in the cluster yet.",
160-
SafeArg.of("numCurrentWaitingExecutors",
160+
SafeArg.of("numTotalCurrentWaitingExecutors",
161161
newlyCreatedExecutors.size + currentPendingExecutors),
162162
SafeArg.of("numCurrentPendingExecutors", currentPendingExecutors),
163163
SafeArg.of("numNewlyCreatedExecutors", newlyCreatedExecutors.size))

0 commit comments

Comments
 (0)