aboutsummaryrefslogtreecommitdiff
path: root/core/src/main/java
Commit message (Collapse)AuthorAgeFilesLines
* Initial work to rename package to org.apache.sparkMatei Zaharia2013-09-017-7/+7
|
* Add Apache license headers and LICENSE and NOTICE filesMatei Zaharia2013-07-167-0/+119
|
* Fix some comments and styleShivaram Venkataraman2013-06-131-1/+1
|
* Make connect timeout configurableShivaram Venkataraman2013-05-311-2/+4
|
* Another round of Netty fixes.Shivaram Venkataraman2013-05-312-18/+14
| | | | | | 1. Avoid race condition between stop and copier completion 2. Handle socket exceptions by reporting them and filling in a failed FetchResult
* Couple of Netty fixesShivaram Venkataraman2013-05-281-21/+24
| | | | | | a. Fix the port number by reading it from the bound channel b. Fix the shutdown sequence to make sure we actually block on the channel c. Fix the unit test to use two JVMs.
* Automatically configure Netty port. This makes unit tests usingReynold Xin2013-05-241-18/+50
| | | | | | | local-cluster pass. Previously they were failing because Netty was trying to bind to the same port for all processes. Pair programmed with @shivaram.
* Cleaned up the Java files from Shane's PR.Reynold Xin2013-05-077-116/+83
|
* fix a bug in netty Block Fetchershane-huang2013-04-161-1/+0
| | | | Signed-off-by: shane-huang <shengsheng.huang@intel.com>
* Shuffle Performance fix: Use netty embeded OIO file server instead of ↵shane-huang2013-04-077-0/+328
ConnectionManager Shuffle Performance Optimization: do not send 0-byte block requests to reduce network messages change reference from io.Source to scala.io.Source to avoid looking into io.netty package Signed-off-by: shane-huang <shengsheng.huang@intel.com>