diff --git a/core/src/test/scala/org/apache/spark/scheduler/TaskSchedulerImplSuite.scala b/core/src/test/scala/org/apache/spark/scheduler/TaskSchedulerImplSuite.scala index 3248e64bcc58..df5031e05887 100644 --- a/core/src/test/scala/org/apache/spark/scheduler/TaskSchedulerImplSuite.scala +++ b/core/src/test/scala/org/apache/spark/scheduler/TaskSchedulerImplSuite.scala @@ -2374,7 +2374,7 @@ class TaskSchedulerImplSuite extends SparkFunSuite with LocalSparkContext // 1 executor with 4 GPUS Seq(true, false).foreach { barrierMode => val barrier = if (barrierMode) "barrier" else "" - (1 to 20).foreach { taskNum => + scala.util.Random.shuffle((1 to 20).toList).take(5).foreach { taskNum => val gpuTaskAmount = ResourceAmountUtils.toFractionalResource(ONE_ENTIRE_RESOURCE / taskNum) test(s"SPARK-45527 TaskResourceProfile with task.gpu.amount=${gpuTaskAmount} can " + s"restrict $taskNum $barrier tasks run in the same executor") { @@ -2423,7 +2423,7 @@ class TaskSchedulerImplSuite extends SparkFunSuite with LocalSparkContext // 4 executors, each of which has 1 GPU Seq(true, false).foreach { barrierMode => val barrier = if (barrierMode) "barrier" else "" - (1 to 20).foreach { taskNum => + scala.util.Random.shuffle((1 to 20).toList).take(5).foreach { taskNum => val gpuTaskAmount = ResourceAmountUtils.toFractionalResource(ONE_ENTIRE_RESOURCE / taskNum) test(s"SPARK-45527 TaskResourceProfile with task.gpu.amount=${gpuTaskAmount} can " + s"restrict $taskNum $barrier tasks run on the different executor") {