Skip to content

Commit 4adb04b

Browse files
committed
Use getTimeAsMs
1 parent 48a3326 commit 4adb04b

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

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

8787
private val initialExecutors = SchedulerBackendUtils.getInitialTargetExecutorNumber(conf)
8888

89-
private val podAllocationInterval = conf.get(KUBERNETES_ALLOCATION_BATCH_DELAY)
89+
private val podAllocationInterval = conf.getTimeAsMs(KUBERNETES_ALLOCATION_BATCH_DELAY.key)
9090

9191
private val podAllocationSize = conf.get(KUBERNETES_ALLOCATION_BATCH_SIZE)
9292

@@ -217,7 +217,7 @@ private[spark] class KubernetesClusterSchedulerBackend(
217217
.watch(new ExecutorPodsWatcher()))
218218

219219
allocatorExecutor.scheduleWithFixedDelay(
220-
allocatorRunnable, 0L, podAllocationInterval.toLong, TimeUnit.MILLISECONDS)
220+
allocatorRunnable, 0L, podAllocationInterval, TimeUnit.MILLISECONDS)
221221

222222
if (!Utils.isDynamicAllocationEnabled(conf)) {
223223
doRequestTotalExecutors(initialExecutors)

0 commit comments

Comments
 (0)