New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[SPARK-7996] Deprecate the developer api SparkEnv.actorSystem #6731
Conversation
@@ -75,7 +75,8 @@ class SparkEnv ( | |||
val conf: SparkConf) extends Logging { | |||
|
|||
// TODO Remove actorSystem | |||
val actorSystem = rpcEnv.asInstanceOf[AkkaRpcEnv].actorSystem | |||
@deprecated("Actor system is no longer supported") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
can you add a version?
Test build #34537 has finished for PR 6731 at commit
|
Test build #34538 has finished for PR 6731 at commit
|
@@ -75,7 +77,8 @@ class SparkEnv ( | |||
val conf: SparkConf) extends Logging { | |||
|
|||
// TODO Remove actorSystem | |||
val actorSystem = rpcEnv.asInstanceOf[AkkaRpcEnv].actorSystem | |||
@deprecated("Actor system is no longer supported as of 1.4") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
i think the idiom for scala deprecation is
@deprecated("Actor system in SparkEnv is no longer supported", "1.4.0")
Test build #34614 has finished for PR 6731 at commit
|
Thanks - merging this in. |
Changed ```SparkEnv.actorSystem``` to be a function such that we can use the deprecated flag with it and added a deprecated message. Author: Ilya Ganelin <ilya.ganelin@capitalone.com> Closes apache#6731 from ilganeli/SPARK-7996 and squashes the following commits: be43817 [Ilya Ganelin] Restored to val 9ed89e7 [Ilya Ganelin] Added a version info for deprecation 9610b08 [Ilya Ganelin] Converted actorSystem to function and added deprecated flag
Changed
SparkEnv.actorSystem
to be a function such that we can use the deprecated flag with it and added a deprecated message.