Skip to content

Commit e857f2e

Browse files
committed
remove unnecessary ClassTag
1 parent e921a66 commit e857f2e

1 file changed

Lines changed: 1 addition & 2 deletions

File tree

core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,6 @@ import scala.collection.mutable.{ArrayBuffer, HashMap, HashSet, Map, Stack}
2626
import scala.concurrent.Await
2727
import scala.concurrent.duration._
2828
import scala.language.postfixOps
29-
import scala.reflect.ClassTag
3029
import scala.util.control.NonFatal
3130

3231
import akka.pattern.ask
@@ -497,7 +496,7 @@ class DAGScheduler(
497496
waiter
498497
}
499498

500-
def runJob[T, U: ClassTag](
499+
def runJob[T, U](
501500
rdd: RDD[T],
502501
func: (TaskContext, Iterator[T]) => U,
503502
partitions: Seq[Int],

0 commit comments

Comments
 (0)