aboutsummaryrefslogtreecommitdiff
path: root/core/src/main/scala/org/apache/spark/rpc
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-13747][CORE] Fix potential ThreadLocal leaks in RPC when using ForkJoi...Shixiong Zhu2016-12-131-9/+3
* [MINOR][CORE][SQL][DOCS] Typo fixesJacek Laskowski2016-12-091-1/+1
* [SPARK-18751][CORE] Fix deadlock when SparkContext.stop is called in Utils.tr...Shixiong Zhu2016-12-083-11/+0
* [SPARK-3359][DOCS] Make javadoc8 working for unidoc/genjavadoc compatibility ...hyukjinkwon2016-11-291-2/+2
* [SPARK-18280][CORE] Fix potential deadlock in `StandaloneSchedulerBackend.dead`Shixiong Zhu2016-11-083-0/+8
* [SPARK-4563][CORE] Allow driver to advertise a different network address.Marcelo Vanzin2016-09-212-6/+20
* [SPARK-16787] SparkContext.addFile() should not throw if called twice with th...Josh Rosen2016-08-021-4/+8
* [SPARK-15541] Casting ConcurrentHashMap to ConcurrentMap (master branch)Maciej Brynski2016-08-021-3/+5
* [SPARK-15913][CORE] Dispatcher.stopped should be enclosed by synchronized block.Dongjoon Hyun2016-06-131-13/+8
* [MINOR] Fix Typos 'a -> an'Zheng RuiFeng2016-05-261-1/+1
* [SPARK-15395][CORE] Use getHostString to create RpcAddressShixiong Zhu2016-05-181-4/+4
* [SPARK-14699][CORE] Stop endpoints before closing the connections and don't s...Shixiong Zhu2016-04-212-7/+4
* [SPARK-14676] Wrap and re-throw Await.result exceptions in order to capture f...Josh Rosen2016-04-191-7/+18
* [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
generated by cgit v1.2.3 (git 2.39.1) at 2024-06-30 06:07:19 +0000