SparkCoreErrors¶

numPartitionsGreaterThanMaxNumConcurrentTasksError¶

numPartitionsGreaterThanMaxNumConcurrentTasksError(
  numPartitions: Int,
  maxNumConcurrentTasks: Int): Throwable

numPartitionsGreaterThanMaxNumConcurrentTasksError creates a BarrierJobSlotsNumberCheckFailed with the given input arguments.

numPartitionsGreaterThanMaxNumConcurrentTasksError is used when:

• DAGScheduler is requested to checkBarrierStageWithNumSlots