Prevent ContextClassLoader of Actor from becoming ClassLoader of Executor.

ueshin · ueshin · commit 43e0febda5cc · 2014-03-28T08:28:10.000+09:00
diff --git a/core/src/main/scala/org/apache/spark/executor/Executor.scala b/core/src/main/scala/org/apache/spark/executor/Executor.scala
@@ -112,11 +112,10 @@ private[spark] class Executor(
     }
   }
 
-  // Create our ClassLoader and set it on this thread
+  // Create our ClassLoader
   // do this after SparkEnv creation so can access the SecurityManager
   private val urlClassLoader = createClassLoader()
   private val replClassLoader = addReplClassLoaderIfNeeded(urlClassLoader)
-  Thread.currentThread.setContextClassLoader(replClassLoader)
 
   // Akka's message frame size. If task result is bigger than this, we use the block manager
   // to send the result back.

Original file line number	Diff line number	Diff line change
`@@ -112,11 +112,10 @@ private[spark] class Executor(`
`112`	`112`	`}`
`113`	`113`	`}`
`114`	`114`
`115`		`- // Create our ClassLoader and set it on this thread`
	`115`	`+ // Create our ClassLoader`
`116`	`116`	`// do this after SparkEnv creation so can access the SecurityManager`
`117`	`117`	`private val urlClassLoader = createClassLoader()`
`118`	`118`	`private val replClassLoader = addReplClassLoaderIfNeeded(urlClassLoader)`
`119`		`- Thread.currentThread.setContextClassLoader(replClassLoader)`
`120`	`119`
`121`	`120`	`// Akka's message frame size. If task result is bigger than this, we use the block manager`
`122`	`121`	`// to send the result back.`