Skip to content

Commit 9ed89e7

Browse files
author
Ilya Ganelin
committed
Added a version info for deprecation
1 parent 9610b08 commit 9ed89e7

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

core/src/main/scala/org/apache/spark/SparkEnv.scala

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,8 @@ package org.apache.spark
2020
import java.io.File
2121
import java.net.Socket
2222

23+
import akka.actor.ActorSystem
24+
2325
import scala.collection.JavaConversions._
2426
import scala.collection.mutable
2527
import scala.util.Properties
@@ -75,8 +77,8 @@ class SparkEnv (
7577
val conf: SparkConf) extends Logging {
7678

7779
// TODO Remove actorSystem
78-
@deprecated("Actor system is no longer supported")
79-
def actorSystem = rpcEnv.asInstanceOf[AkkaRpcEnv].actorSystem
80+
@deprecated("Actor system is no longer supported as of 1.4")
81+
def actorSystem: ActorSystem = rpcEnv.asInstanceOf[AkkaRpcEnv].actorSystem
8082

8183
private[spark] var isStopped = false
8284
private val pythonWorkers = mutable.HashMap[(String, Map[String, String]), PythonWorkerFactory]()

0 commit comments

Comments
 (0)