add missing line

witgo · Apr 5, 2014 · 04b9662 · 04b9662
1 parent 4803c19
commit 04b9662
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/core/src/main/scala/org/apache/spark/executor/MesosExecutorBackend.scala b/core/src/main/scala/org/apache/spark/executor/MesosExecutorBackend.scala
@@ -52,6 +52,7 @@ private[spark] class MesosExecutorBackend
       slaveInfo: SlaveInfo) {
     val cl = Thread.currentThread.getContextClassLoader
     try {
+      Thread.currentThread.setContextClassLoader(getClass.getClassLoader)
       logInfo("Registered with Mesos as executor ID " + executorInfo.getExecutorId.getValue)
       this.driver = driver
       val properties = Utils.deserialize[Array[(String, String)]](executorInfo.getData.toByteArray)