Step 1 of 4: Choose Issues

Cancel

T Patch Info Key Summary Assignee Reporter P Status Resolution Created Updated Due Development
Sub-task SPARK-11230

SPARK-5293 Add Outbox to cache the sending messages to resolve the message disorder issue

Unassigned Shixiong Zhu Major Closed Duplicate  
Sub-task SPARK-11098

SPARK-5293 RPC message ordering is not guaranteed

Shixiong Zhu Reynold Xin Major Resolved Fixed  
Sub-task 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 Major Resolved Fixed  
Sub-task SPARK-11096

SPARK-5293 Post-hoc review Netty based RPC implementation - round 2

Reynold Xin Reynold Xin Major Resolved Fixed  
Sub-task SPARK-11079

SPARK-5293 Post-hoc review Netty based RPC implementation - round 1

Reynold Xin Reynold Xin Major Resolved Fixed  
Sub-task SPARK-11073

SPARK-5293 Remove akka dependency from SecurityManager

Marcelo Masiero Vanzin Marcelo Masiero Vanzin Minor Resolved Fixed  
Sub-task SPARK-9602

SPARK-5293 Remove 'Actor' from the comments

Nan Zhu Nan Zhu Major Resolved Fixed  
Sub-task SPARK-7997

SPARK-5293 Remove the developer api SparkEnv.actorSystem and AkkaUtils

Shixiong Zhu Shixiong Zhu Major Resolved Fixed  
Sub-task SPARK-7996

SPARK-5293 Deprecate the developer api SparkEnv.actorSystem

Ilya Ganelin Shixiong Zhu Major Resolved Fixed  
Sub-task SPARK-7995

SPARK-5293 Remove AkkaRpcEnv and remove Akka from the dependencies of Core

Shixiong Zhu Shixiong Zhu Major Resolved Fixed  
Sub-task SPARK-7994

SPARK-5293 Remove "StreamingContext.actorStream"

Shixiong Zhu Shixiong Zhu Major Resolved Fixed  
Sub-task SPARK-7799

SPARK-5293 Move "StreamingContext.actorStream" to a separate project and deprecate it in StreamingContext

Shixiong Zhu Shixiong Zhu Major Resolved Fixed  
Sub-task SPARK-7798

SPARK-5293 Move "AkkaRpcEnv" to a separate project

Unassigned Shixiong Zhu Major Resolved Duplicate  
Sub-task SPARK-7797

SPARK-5293 Remove "actorSystem" from SparkEnv

Unassigned Shixiong Zhu Major Resolved Duplicate  
Sub-task SPARK-7796

SPARK-5293 Use the new RPC implementation by default

Shixiong Zhu Shixiong Zhu Major Resolved Fixed  
Sub-task SPARK-7223

SPARK-5293 Rename RPC askWithReply -> askWithReply, sendWithReply -> ask

Reynold Xin Reynold Xin Major Resolved Fixed  
Sub-task SPARK-7174

SPARK-5293 Move calling `TaskScheduler.executorHeartbeatReceived` to another thread to avoid blocking the Akka thread pool

Shixiong Zhu Shixiong Zhu Major Resolved Fixed  
Sub-task SPARK-6983

SPARK-5293 Update ReceiverTrackerActor to use the new Rpc interface

Shixiong Zhu Shixiong Zhu Major Resolved Fixed  
Sub-task SPARK-6979

SPARK-5293 Replace JobScheduler.eventActor and JobGenerator.eventActor with EventLoop

Shixiong Zhu Shixiong Zhu Minor Resolved Fixed  
Sub-task SPARK-6602

SPARK-5293 Replace direct use of Akka with Spark RPC interface

Shixiong Zhu Reynold Xin Critical Resolved Fixed  
Sub-task SPARK-6490

SPARK-5293 Deprecate configurations for "askWithReply" and use new configuration names

Shixiong Zhu Shixiong Zhu Major Resolved Fixed  
Sub-task SPARK-6280

SPARK-5293 Remove Akka systemName from Spark

Shixiong Zhu Shixiong Zhu Major Resolved Fixed  
Sub-task SPARK-6028

SPARK-5293 Provide an alternative RPC implementation based on the network transport module

Shixiong Zhu Reynold Xin Critical Resolved Fixed  
Sub-task SPARK-5214

SPARK-5293 Add EventLoop and change DAGScheduler to an EventLoop

Shixiong Zhu Shixiong Zhu Major Resolved Fixed  
Sub-task SPARK-5124

SPARK-5293 Standardize internal RPC interface

Shixiong Zhu Reynold Xin Major Resolved Fixed  

Cancel