diff --git a/core/src/main/scala/spark/Executor.scala b/core/src/main/scala/spark/Executor.scala index f32e66bef471dcbe3be2ebf0b08e204660eb005a..7764acad1acc27492961c4832476b3124b9b32d2 100644 --- a/core/src/main/scala/spark/Executor.scala +++ b/core/src/main/scala/spark/Executor.scala @@ -108,7 +108,7 @@ class Executor extends mesos.Executor with Logging { loader = { try { val klass = Class.forName("spark.repl.ExecutorClassLoader").asInstanceOf[Class[_ <: ClassLoader]] - val constructor = klass.getConstructor(classUri.getClass, loader.getClass) + val constructor = klass.getConstructor(classOf[String], classOf[ClassLoader]) constructor.newInstance(classUri, loader) } catch { case _: ClassNotFoundException => loader