Commit message (Expand) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | SPARK-940: Do not directly pass Stage objects to SparkListener. | Patrick Wendell | 2013-10-22 | 9 | -59/+75 |
* | Merge pull request #98 from aarondav/docs | Matei Zaharia | 2013-10-22 | 1 | -3/+3 |
|\ | |||||
| * | Docs: Fix links to RDD API documentation | Aaron Davidson | 2013-10-22 | 1 | -3/+3 |
* | | Merge pull request #82 from JoshRosen/map-output-tracker-refactoring | Matei Zaharia | 2013-10-22 | 5 | -98/+109 |
|\ \ | |||||
| * | | Unwrap a long line that actually fits. | Josh Rosen | 2013-10-20 | 1 | -2/+1 |
| * | | Fix test failures in local mode due to updateEpoch | Josh Rosen | 2013-10-20 | 1 | -4/+1 |
| * | | Split MapOutputTracker into Master/Worker classes. | Josh Rosen | 2013-10-19 | 5 | -98/+113 |
* | | | Merge pull request #92 from tgravescs/sparkYarnFixClasspath | Matei Zaharia | 2013-10-21 | 2 | -10/+29 |
|\ \ \ | |||||
| * | | | Fix the Worker to use CoarseGrainedExecutorBackend and modify classpath to be... | tgravescs | 2013-10-21 | 2 | -10/+29 |
* | | | | Merge pull request #56 from jerryshao/kafka-0.8-dev | Matei Zaharia | 2013-10-21 | 19 | -116/+250 |
|\ \ \ \ | |||||
| * | | | | Upgrade Kafka 0.7.2 to Kafka 0.8.0-beta1 for Spark Streaming | jerryshao | 2013-10-12 | 19 | -110/+250 |
* | | | | | Merge pull request #87 from aarondav/shuffle-base | Reynold Xin | 2013-10-21 | 13 | -319/+460 |
|\ \ \ \ \ | |_|_|_|/ |/| | | | | |||||
| * | | | | Merge ShufflePerfTester patch into shuffle block consolidation | Aaron Davidson | 2013-10-21 | 19 | -490/+551 |
| |\ \ \ \ | |/ / / / |/| | | | | |||||
* | | | | | Merge pull request #95 from aarondav/perftest | Reynold Xin | 2013-10-21 | 1 | -0/+0 |
|\ \ \ \ \ | |||||
| * | | | | | Put StoragePerfTester in org/apache/ | Aaron Davidson | 2013-10-21 | 1 | -0/+0 |
* | | | | | | Merge pull request #94 from aarondav/mesos-fix | Matei Zaharia | 2013-10-21 | 1 | -2/+2 |
|\ \ \ \ \ \ | |/ / / / / |/| | | | | | |||||
| * | | | | | Fix mesos urls | Aaron Davidson | 2013-10-21 | 1 | -2/+2 |
|/ / / / / | |||||
* | | | | | Merge pull request #88 from rxin/clean | Patrick Wendell | 2013-10-21 | 7 | -101/+113 |
|\ \ \ \ \ | |_|_|/ / |/| | | | | |||||
| * | | | | Made JobLogger public again and some minor cleanup. | Reynold Xin | 2013-10-20 | 1 | -68/+54 |
| * | | | | Made the following traits/interfaces/classes non-public: | Reynold Xin | 2013-10-20 | 7 | -39/+65 |
* | | | | | Merge pull request #41 from pwendell/shuffle-benchmark | Patrick Wendell | 2013-10-20 | 6 | -4/+141 |
|\ \ \ \ \ | |||||
| * | | | | | Making the timing block more narrow for the sync | Patrick Wendell | 2013-10-07 | 1 | -2/+2 |
| * | | | | | Minor cleanup | Patrick Wendell | 2013-10-07 | 3 | -66/+45 |
| * | | | | | Perf benchmark | Patrick Wendell | 2013-10-07 | 1 | -0/+89 |
| * | | | | | Trying new approach with writes | Patrick Wendell | 2013-10-07 | 2 | -7/+7 |
| * | | | | | Adding option to force sync to the filesystem | Patrick Wendell | 2013-10-07 | 1 | -3/+17 |
| * | | | | | Track and report write throughput for shuffle tasks. | Patrick Wendell | 2013-10-07 | 5 | -2/+57 |
* | | | | | | Merge pull request #89 from rxin/executor | Reynold Xin | 2013-10-20 | 1 | -20/+23 |
|\ \ \ \ \ \ | |||||
| * | | | | | | Don't setup the uncaught exception handler in local mode. | Reynold Xin | 2013-10-20 | 1 | -20/+23 |
| | |/ / / / | |/| | | | | |||||
* | | | | | | Merge pull request #80 from rxin/build | Matei Zaharia | 2013-10-20 | 3 | -44/+60 |
|\ \ \ \ \ \ | |||||
| * | | | | | | Exclusion rules for Maven build files. | Reynold Xin | 2013-10-19 | 3 | -44/+60 |
* | | | | | | | Merge pull request #75 from JoshRosen/block-manager-cleanup | Matei Zaharia | 2013-10-20 | 1 | -292/+166 |
|\ \ \ \ \ \ \ | |||||
| * | | | | | | | Minor cleanup based on @aarondav's code review. | Josh Rosen | 2013-10-20 | 1 | -11/+5 |
| * | | | | | | | De-duplicate code in dropOld[Non]BroadcastBlocks. | Josh Rosen | 2013-10-19 | 1 | -20/+6 |
| * | | | | | | | Code de-duplication in put() and putBytes(). | Josh Rosen | 2013-10-19 | 1 | -140/+89 |
| * | | | | | | | De-duplication in getRemote() and getRemoteBytes(). | Josh Rosen | 2013-10-19 | 1 | -32/+18 |
| * | | | | | | | De-duplication in getLocal() and getLocalBytes(). | Josh Rosen | 2013-10-19 | 1 | -100/+59 |
| | |_|_|_|_|/ | |/| | | | | | |||||
* | | | | | | | Merge pull request #84 from rxin/kill1 | Reynold Xin | 2013-10-20 | 1 | -21/+38 |
|\ \ \ \ \ \ \ | |_|_|/ / / / |/| | | | | | | |||||
| * | | | | | | Updated setGroupId documentation and marked dagSchedulerSource and blockManag... | Reynold Xin | 2013-10-20 | 1 | -4/+4 |
| * | | | | | | Added documentation for setJobGroup. Also some minor cleanup in SparkContext. | Reynold Xin | 2013-10-19 | 1 | -19/+36 |
| | |/ / / / | |/| | | | | |||||
* | | | | | | Merge pull request #85 from rxin/clean | Matei Zaharia | 2013-10-20 | 1 | -0/+2 |
|\ \ \ \ \ \ | |||||
| * | | | | | | Moved the top level spark package object from spark to org.apache.spark | Reynold Xin | 2013-10-19 | 1 | -0/+2 |
| |/ / / / / | |||||
| | | | * | | Remove executorId from Task.run() | Aaron Davidson | 2013-10-21 | 3 | -3/+3 |
| | | | * | | Documentation update | Aaron Davidson | 2013-10-20 | 1 | -3/+1 |
| | | | * | | Close shuffle writers during failure & remove executorId from TaskContext | Aaron Davidson | 2013-10-20 | 7 | -15/+13 |
| | | | * | | Cleanup old shuffle file metadata from memory | Aaron Davidson | 2013-10-20 | 2 | -7/+13 |
| | | | * | | Address Josh and Reynold's comments | Aaron Davidson | 2013-10-20 | 6 | -18/+17 |
| | | | * | | Fix compiler errors | Aaron Davidson | 2013-10-20 | 3 | -5/+5 |
| | | | * | | Basic shuffle file consolidation | Aaron Davidson | 2013-10-20 | 8 | -14/+57 |
| | | | * | | Refactor of DiskStore for shuffle file consolidation | Aaron Davidson | 2013-10-20 | 10 | -269/+366 |
| |_|_|/ / |/| | | | |