From 04b966264e37d66eef7e6b057e1b8fb824712895 Mon Sep 17 00:00:00 2001 From: Bharath Bhushan Date: Sat, 5 Apr 2014 01:49:29 +0000 Subject: [PATCH] add missing line --- .../scala/org/apache/spark/executor/MesosExecutorBackend.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/core/src/main/scala/org/apache/spark/executor/MesosExecutorBackend.scala b/core/src/main/scala/org/apache/spark/executor/MesosExecutorBackend.scala index ea1e85649469c..20bcb26f134db 100644 --- 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)