File tree Expand file tree Collapse file tree 1 file changed +1
-2
lines changed
core/src/main/scala/org/apache/spark/scheduler Expand file tree Collapse file tree 1 file changed +1
-2
lines changed Original file line number Diff line number Diff line change @@ -448,7 +448,7 @@ private[spark] class TaskSetManager(
448
448
// Found a task; do some bookkeeping and return a task description
449
449
val task = tasks(index)
450
450
val taskId = sched.newTaskId()
451
-
451
+
452
452
val executorManager = sched.sc.executorAllocationManager.getOrElse(null )
453
453
if (executorManager != null ) {
454
454
if (! executorManager.isExecutorPendingToRemove(execId)) {
@@ -484,7 +484,6 @@ private[spark] class TaskSetManager(
484
484
abort(s " $msg Exception during serialization: $e" )
485
485
throw new TaskNotSerializableException (e)
486
486
}
487
-
488
487
if (serializedTask.limit > TaskSetManager .TASK_SIZE_TO_WARN_KB * 1024 &&
489
488
! emittedTaskSizeWarning) {
490
489
emittedTaskSizeWarning = true
You can’t perform that action at this time.
0 commit comments