aboutsummaryrefslogtreecommitdiff
path: root/core/src/main/scala/org/apache/spark/rpc
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-13928] Move org.apache.spark.Logging into org.apache.spark.internal.Lo...Wenchen Fan2016-03-176-6/+11
* [SPARK-13906] Ensure that there are at least 2 dispatcher threads.Yonathan Randolph2016-03-161-1/+1
* [MINOR] a minor fix for the comments of a method in RPC DispatcherCodingCat2016-03-151-1/+1
* [SPARK-3854][BUILD] Scala style: require spaces before `{`.Dongjoon Hyun2016-03-101-1/+1
* [SPARK-13583][CORE][STREAMING] Remove unused imports and add checkstyle ruleDongjoon Hyun2016-03-031-1/+0
* [SPARK-12967][NETTY] Avoid NettyRpc error message during sparkContext shutdownNishkam Ravi2016-01-264-5/+32
* [SPARK-12614][CORE] Don't throw non fatal exception from askShixiong Zhu2016-01-261-25/+29
* [SPARK-3873][CORE] Import ordering fixes.Marcelo Vanzin2016-01-053-5/+4
* [SPARK-7995][SPARK-6280][CORE] Remove AkkaRpcEnv and remove systemName from s...Shixiong Zhu2015-12-314-434/+14
* Minor corrections, i.e. typo fixes and follow deprecatedJacek Laskowski2015-12-221-1/+1
* [SPARK-11097][CORE] Add channelActive callback to RpcHandler to monitor the n...Shixiong Zhu2015-12-181-9/+8
* [SPARK-12350][CORE] Don't log errors when requested stream is not found.Marcelo Vanzin2015-12-182-11/+13
* [SPARK-12220][CORE] Make Utils.fetchFile support files that contain special c...Shixiong Zhu2015-12-171-2/+3
* [MINOR] Add missing interpolation in NettyRPCEnvAndrew Or2015-12-161-1/+1
* [SPARK-12267][CORE] Store the remote RpcEnv address to send the correct disco...Shixiong Zhu2015-12-121-0/+21
* [SPARK-11563][CORE][REPL] Use RpcEnv to transfer REPL-generated classes.Marcelo Vanzin2015-12-103-1/+44
* [SPARK-12007][NETWORK] Avoid copies in the network lib's RPC layer.Marcelo Vanzin2015-11-302-13/+12
* [SPARK-11866][NETWORK][CORE] Make sure timed out RPCs are cleaned up.Marcelo Vanzin2015-11-255-182/+153
* [SPARK-11956][CORE] Fix a few bugs in network lib-based file transfer.Marcelo Vanzin2015-11-252-6/+15
* [SPARK-11140][CORE] Transfer files using network lib when using NettyRpcEnv.Marcelo Vanzin2015-11-234-18/+289
* [SPARK-11830][CORE] Make NettyRpcEnv bind to the specified hostzsxwing2015-11-191-4/+3
* [SPARK-10745][CORE] Separate configs between shuffle and RPCShixiong Zhu2015-11-181-5/+3
* [SPARK-11786][CORE] Tone down messages from akka error monitor.Marcelo Vanzin2015-11-171-1/+1
* [SPARK-11615] Drop @VisibleForTesting annotationtedyu2015-11-101-4/+4
* [SPARK-9790][YARN] Expose in WebUI if NodeManager is the reason why executors...Mark Grover2015-11-031-2/+2
* [SPARK-10997][CORE] Add "client mode" to netty rpc env.Marcelo Vanzin2015-11-025-128/+175
* [SPARK-11098][CORE] Add Outbox to cache the sending messages to resolve the m...zsxwing2015-10-222-57/+310
* [SPARK-11232][CORE] Use 'offer' instead of 'put' to make sure calling send wo...zsxwing2015-10-221-5/+5
* [SPARK-11110][BUILD] Remove transient annotation for parameters.Jakob Odersky2015-10-201-1/+1
* [SPARK-11096] Post-hoc review Netty based RPC implementation - round 2Reynold Xin2015-10-145-103/+80
* [SPARK-11079] Post-hoc review Netty-based RPC - round 1Reynold Xin2015-10-1310-294/+327
* [SPARK-6028] [CORE] Remerge #6457: new RPC implemetation and also pick #8905zsxwing2015-10-0311-31/+1186
* Revert "[SPARK-6028][Core]A new RPC implemetation based on the network module"Xiangrui Meng2015-09-2411-1181/+31
* [SPARK-6028][Core]A new RPC implemetation based on the network modulezsxwing2015-09-2311-31/+1181
* [SPARK-10227] fatal warnings with sbt on Scala 2.11Luc Bourlier2015-09-092-8/+15
* [SPARK-9602] remove "Akka/Actor" words from commentsCodingCat2015-08-041-1/+1
* [SPARK-8873] [MESOS] Clean up shuffle files if external shuffle service is usedTimothy Chen2015-08-031-3/+3
* [SPARK-6602][Core]Replace Akka Serialization with Spark Serializerzsxwing2015-07-152-1/+19
* [SPARK-8962] Add Scalastyle rule to ban direct use of Class.forName; fix exis...Josh Rosen2015-07-141-2/+1
* [SPARK-6980] [CORE] Akka timeout exceptions indicate which conf controls them...Bryan Cutler2015-07-023-16/+128
* [SPARK-6602][Core] Update Master, Worker, Client, AppClient and related class...zsxwing2015-06-302-4/+6
* [SPARK-7655][Core][SQL] Remove 'scala.concurrent.ExecutionContext.Implicits.g...zsxwing2015-05-161-3/+5
* [SPARK-7223] Rename RPC askWithReply -> askWithReply, sendWithReply -> ask.Reynold Xin2015-04-295-280/+343
* [SPARK-6490][Core] Add spark.rpc.* and deprecate spark.akka.*zsxwing2015-04-201-5/+5
* [SPARK-6983][Streaming] Update ReceiverTrackerActor to use the new Rpc interfacezsxwing2015-04-191-1/+1
* [SPARK-6934][Core] Use 'spark.akka.askTimeout' for the ask timeoutzsxwing2015-04-161-3/+4
* [SPARK-6602][Core] Update MapOutputTrackerMasterActor to MapOutputTrackerMast...zsxwing2015-04-052-3/+20
* [SPARK-6602][Core] Replace direct use of Akka with Spark RPC interface - part 1zsxwing2015-04-042-30/+19
* [SPARK-5124][Core] A standard RPC interface and an Akka implementationzsxwing2015-03-292-0/+747
generated by cgit v1.2.3 (git 2.39.1) at 2024-08-01 03:22:48 +0000