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(
448448 // Found a task; do some bookkeeping and return a task description
449449 val task = tasks(index)
450450 val taskId = sched.newTaskId()
451-
451+
452452 val executorManager = sched.sc.executorAllocationManager.getOrElse(null )
453453 if (executorManager != null ) {
454454 if (! executorManager.isExecutorPendingToRemove(execId)) {
@@ -484,7 +484,6 @@ private[spark] class TaskSetManager(
484484 abort(s " $msg Exception during serialization: $e" )
485485 throw new TaskNotSerializableException (e)
486486 }
487-
488487 if (serializedTask.limit > TaskSetManager .TASK_SIZE_TO_WARN_KB * 1024 &&
489488 ! emittedTaskSizeWarning) {
490489 emittedTaskSizeWarning = true
You can’t perform that action at this time.
0 commit comments