|
|
|
SPARK-11230
|
SPARK-5293
Add Outbox to cache the sending messages to resolve the message disorder issue
|
Unassigned
|
Shixiong Zhu
|
|
Closed |
Duplicate
|
|
|
|
|
|
|
|
SPARK-11098
|
SPARK-5293
RPC message ordering is not guaranteed
|
Shixiong Zhu
|
Reynold Xin
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11097
|
SPARK-5293
Add connection established callback to lower level RPC layer so we don't need to check for new connections in NettyRpcHandler.receive
|
Shixiong Zhu
|
Reynold Xin
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11096
|
SPARK-5293
Post-hoc review Netty based RPC implementation - round 2
|
Reynold Xin
|
Reynold Xin
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11079
|
SPARK-5293
Post-hoc review Netty based RPC implementation - round 1
|
Reynold Xin
|
Reynold Xin
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11073
|
SPARK-5293
Remove akka dependency from SecurityManager
|
Marcelo Masiero Vanzin
|
Marcelo Masiero Vanzin
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-9602
|
SPARK-5293
Remove 'Actor' from the comments
|
Nan Zhu
|
Nan Zhu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-7997
|
SPARK-5293
Remove the developer api SparkEnv.actorSystem and AkkaUtils
|
Shixiong Zhu
|
Shixiong Zhu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-7996
|
SPARK-5293
Deprecate the developer api SparkEnv.actorSystem
|
Ilya Ganelin
|
Shixiong Zhu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-7995
|
SPARK-5293
Remove AkkaRpcEnv and remove Akka from the dependencies of Core
|
Shixiong Zhu
|
Shixiong Zhu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-7994
|
SPARK-5293
Remove "StreamingContext.actorStream"
|
Shixiong Zhu
|
Shixiong Zhu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-7799
|
SPARK-5293
Move "StreamingContext.actorStream" to a separate project and deprecate it in StreamingContext
|
Shixiong Zhu
|
Shixiong Zhu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-7798
|
SPARK-5293
Move "AkkaRpcEnv" to a separate project
|
Unassigned
|
Shixiong Zhu
|
|
Resolved |
Duplicate
|
|
|
|
|
|
|
|
SPARK-7797
|
SPARK-5293
Remove "actorSystem" from SparkEnv
|
Unassigned
|
Shixiong Zhu
|
|
Resolved |
Duplicate
|
|
|
|
|
|
|
|
SPARK-7796
|
SPARK-5293
Use the new RPC implementation by default
|
Shixiong Zhu
|
Shixiong Zhu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-7223
|
SPARK-5293
Rename RPC askWithReply -> askWithReply, sendWithReply -> ask
|
Reynold Xin
|
Reynold Xin
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-7174
|
SPARK-5293
Move calling `TaskScheduler.executorHeartbeatReceived` to another thread to avoid blocking the Akka thread pool
|
Shixiong Zhu
|
Shixiong Zhu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-6983
|
SPARK-5293
Update ReceiverTrackerActor to use the new Rpc interface
|
Shixiong Zhu
|
Shixiong Zhu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-6979
|
SPARK-5293
Replace JobScheduler.eventActor and JobGenerator.eventActor with EventLoop
|
Shixiong Zhu
|
Shixiong Zhu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-6602
|
SPARK-5293
Replace direct use of Akka with Spark RPC interface
|
Shixiong Zhu
|
Reynold Xin
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-6490
|
SPARK-5293
Deprecate configurations for "askWithReply" and use new configuration names
|
Shixiong Zhu
|
Shixiong Zhu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-6280
|
SPARK-5293
Remove Akka systemName from Spark
|
Shixiong Zhu
|
Shixiong Zhu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-6028
|
SPARK-5293
Provide an alternative RPC implementation based on the network transport module
|
Shixiong Zhu
|
Reynold Xin
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-5214
|
SPARK-5293
Add EventLoop and change DAGScheduler to an EventLoop
|
Shixiong Zhu
|
Shixiong Zhu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-5124
|
SPARK-5293
Standardize internal RPC interface
|
Shixiong Zhu
|
Reynold Xin
|
|
Resolved |
Fixed
|
|
|
|
|