diff options
| author | Imran Rashid <imran@quantifind.com> | 2013-05-13 16:37:49 -0700 |
|---|---|---|
| committer | Imran Rashid <imran@quantifind.com> | 2013-05-14 22:32:09 -0700 |
| commit | d7d1da79d30961e461115a73bbfc9e4c4448e533 (patch) | |
| tree | 53db9f3188ce111449a436330c6ad254264b4bdf /core | |
| parent | 016ac868303adbffb19165430610869363fa943f (diff) | |
| download | spark-d7d1da79d30961e461115a73bbfc9e4c4448e533.tar.gz spark-d7d1da79d30961e461115a73bbfc9e4c4448e533.tar.bz2 spark-d7d1da79d30961e461115a73bbfc9e4c4448e533.zip | |
when akka starts, use akkas default classloader (current thread)
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/util/AkkaUtils.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/util/AkkaUtils.scala b/core/src/main/scala/spark/util/AkkaUtils.scala index 9fb7e001ba..cd79bd2bda 100644 --- a/core/src/main/scala/spark/util/AkkaUtils.scala +++ b/core/src/main/scala/spark/util/AkkaUtils.scala @@ -52,7 +52,7 @@ private[spark] object AkkaUtils { """.format(host, port, akkaTimeout, akkaFrameSize, akkaThreads, akkaBatchSize, lifecycleEvents, akkaWriteTimeout)) - val actorSystem = ActorSystem(name, akkaConf, getClass.getClassLoader) + val actorSystem = ActorSystem(name, akkaConf) // Figure out the port number we bound to, in case port was passed as 0. This is a bit of a // hack because Akka doesn't let you figure out the port through the public API yet. |