aboutsummaryrefslogtreecommitdiff
path: root/core
Commit message (Expand)AuthorAgeFilesLines
...
| | * | | | ExecutorLostReason -> ExecutorLossReasonCharles Reiss2012-12-134-6/+6
| | * | | | Extra whitespace in ExecutorExitCodeCharles Reiss2012-12-131-0/+3
| | * | | | Explain slaveLost calls made by StandaloneSchedulerBackendCharles Reiss2012-12-131-5/+5
| | * | | | Log duplicate slaveLost() calls in ClusterScheduler.Charles Reiss2012-12-131-1/+7
| | * | | | Normalize executor exit statuses and report them to the user.Charles Reiss2012-12-138-11/+94
| | * | | | Call slaveLost on executor death for standalone clusters.Charles Reiss2012-12-121-1/+12
| | |/ / /
| * | | | SPARK-635: Pass a TaskContext object to compute() interface and useReynold Xin2012-12-1320-49/+46
| * | | | SPARK-635: Pass a TaskContext object to compute() interface and use thatReynold Xin2012-12-1326-205/+207
| |/ / /
| * | | Suppress shuffle block updates when a slave node comes back.Reynold Xin2012-12-102-12/+17
| * | | Merge pull request #317 from woggling/block-manager-heartbeatMatei Zaharia2012-12-106-62/+318
| |\ \ \
| | * | | Decrease BlockManagerMaster logging verbosityCharles Reiss2012-12-101-1/+2
| | * | | Use Akka scheduler for BlockManager heart beats.Charles Reiss2012-12-104-49/+41
| | * | | Changed default block manager heartbeat interval to 5 sCharles Reiss2012-12-091-1/+1
| | * | | Don't divide by milliseconds by 1000 more.Charles Reiss2012-12-061-1/+1
| | * | | map -> foreachCharles Reiss2012-12-061-1/+1
| | * | | Make LocalSparkCluster use distinct IPsCharles Reiss2012-12-061-2/+6
| | * | | Tests for block manager heartbeats.Charles Reiss2012-12-051-0/+68
| | * | | Add block manager heart beats.Charles Reiss2012-12-052-25/+193
| | * | | Track block managers by hostname; handle manager removal.Charles Reiss2012-12-051-3/+27
| | * | | Actually put millis in _lastSeenMsCharles Reiss2012-12-051-1/+1
| | * | | Don't use bogus port number in notifyADeadHost().Charles Reiss2012-12-051-2/+1
| * | | | Merge pull request #310 from tomdz/master-mavenizedMatei Zaharia2012-12-091-0/+270
| |\ \ \ \
| | * | | | Code review feedback fixThomas Dudziak2012-11-281-1/+12
| | * | | | Updated versions in the pom.xml files to match current masterThomas Dudziak2012-11-271-1/+1
| | * | | | Addressed code review commentsThomas Dudziak2012-11-271-0/+1
| | * | | | Added maven and debian build filesThomas Dudziak2012-11-201-0/+258
| * | | | | Search for a non-loopback address in Utils.getLocalIpAddressMatei Zaharia2012-12-085-10/+33
| | |/ / / | |/| | |
| * | | | Use external addresses in standalone WebUI on EC2.Josh Rosen2012-12-015-12/+30
| * | | | Merge pull request #313 from rxin/pde_size_compressMatei Zaharia2012-11-272-33/+37
| |\ \ \ \
| | * | | | Added a partition preserving flag to MapPartitionsWithSplitRDD.Reynold Xin2012-11-272-33/+37
| * | | | | Added zip to Java APIMatei Zaharia2012-11-272-0/+25
| * | | | | Added a zip() operation for RDDs with the same shape (number ofMatei Zaharia2012-11-273-0/+75
| * | | | | Merge branch 'master' of github.com:mesos/sparkMatei Zaharia2012-11-275-18/+92
| |\ \ \ \ \
| | * \ \ \ \ Merge pull request #311 from woggling/map-output-npeMatei Zaharia2012-11-272-1/+52
| | |\ \ \ \ \ | | | |/ / / / | | |/| | | |
| | | * | | | Fix NullPointerException when unregistering a map output twice.Charles Reiss2012-11-271-1/+1
| | | * | | | Tests for MapOutputTracker.Charles Reiss2012-11-271-0/+51
| | | |/ / /
| | * / / / For size compression, compress non zero values into non zero values.Reynold Xin2012-11-272-15/+18
| | |/ / /
| * | | | Fix NullPointerException caused by unregistered map outputs.Josh Rosen2012-11-272-2/+8
* | | | | Added clear property to JavaAPISuite to remove port binding errors.Tathagata Das2012-12-111-0/+2
* | | | | Merge pull request #5 from radlab/flume-integrationTathagata Das2012-12-092-3/+18
|\ \ \ \ \
| * | | | | Changes in response to TD's review.Patrick Wendell2012-12-071-3/+3
| * | | | | Adding locality aware parallelizePatrick Wendell2012-12-072-3/+18
| | |_|/ / | |/| | |
* / | | | Removed unnecessary testcases.Tathagata Das2012-12-081-4/+4
|/ / / /
* | | | Added metadata cleaner to HttpBroadcast to clean up old broacast files.Tathagata Das2012-12-031-0/+24
* | | | Made RDD checkpoint not create a new thread. Fixed bug in detecting when spar...Tathagata Das2012-12-022-22/+12
* | | | Minor modifications.Tathagata Das2012-12-011-1/+6
* | | | Added TimeStampedHashSet and used that to cleanup the list of registered RDD ...Tathagata Das2012-11-293-9/+81
* | | | Added metadata cleaner to BlockManager to remove old blocks completely.Tathagata Das2012-11-282-12/+36
* | | | Renamed CleanupTask to MetadataCleaner.Tathagata Das2012-11-285-14/+15
* | | | Modified StorageLevel and BlockManagerId to cache common objects and use cach...Tathagata Das2012-11-284-29/+101