aboutsummaryrefslogtreecommitdiff
path: root/core
Commit message (Collapse)AuthorAgeFilesLines
...
| * | | | | Merge pull request #611 from squito/classloaderMatei Zaharia2013-05-282-4/+11
| |\ \ \ \ \ | | |/ / / / | |/| | | | Use default classloaders for akka & deserializing task results
| | * | | | use threads classloader when deserializing task results; ↵Imran Rashid2013-05-141-3/+10
| | | | | | | | | | | | | | | | | | | | | | | | classnotfoundexception includes classloader
| | * | | | when akka starts, use akkas default classloader (current thread)Imran Rashid2013-05-141-1/+1
| | | | | |
| * | | | | Merge pull request #620 from jerryshao/masterMatei Zaharia2013-05-271-1/+1
| |\ \ \ \ \ | | | | | | | | | | | | | | Fix CheckpointRDD java.io.FileNotFoundException when calling getPreferredLocations
| | * | | | | fix CheckpointRDD getPreferredLocations java.io.FileNotFoundExceptionjerryshao2013-05-241-1/+1
| | | | | | |
| * | | | | | Merge pull request #529 from xiajunluan/masterMatei Zaharia2013-05-2515-41/+716
| |\ \ \ \ \ \ | | | |_|_|/ / | | |/| | | | [SPARK-663]Implement Fair Scheduler in Spark Cluster Scheduler
| | * | | | | fix bug of unit testsAndrew xia2013-05-212-35/+43
| | | | | | |
| | * | | | | Merge branch 'master' into xiajunluanAndrew xia2013-05-18152-1396/+7022
| | |\ \ \ \ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Conflicts: core/src/main/scala/spark/SparkContext.scala core/src/main/scala/spark/scheduler/cluster/ClusterScheduler.scala core/src/main/scala/spark/scheduler/cluster/TaskSetManager.scala
| | * | | | | | expose TaskSetManager type to resourceOffer function in ClusterSchedulerAndrew xia2013-05-186-70/+84
| | | | | | | |
| | * | | | | | Fix ClusterScheduler bug to avoid allocating tasks to same slaveAndrew xia2013-05-175-50/+75
| | | | | | | |
| | * | | | | | remove TaskSetQueueManager and update code styleAndrew xia2013-04-194-32/+9
| | | | | | | |
| | * | | | | | refactor the Schedulable interface and add unit test for SchedulingAlgorithmAndrew xia2013-04-1811-316/+525
| | | | | | | |
| | * | | | | | Contiue to update codes for scala code styleAndrew xia2013-04-0911-147/+122
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 1.refactor braces for "class" "if" "while" "for" "match" 2.make code lines less than 100 3.refactor class parameter and extends defination
| | * | | | | | add properties default value null to fix sbt/sbt test errorsAndrew xia2013-04-021-1/+1
| | | | | | | |
| | * | | | | | change some typo and some spacingAndrew xia2013-03-293-11/+10
| | | | | | | |
| | * | | | | | 1.remove redundant spacing in source codeAndrew xia2013-03-2911-144/+91
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 2.replace get/set functions with val and var defination
| | * | | | | | Just update typo and commentsAndrew xia2013-03-232-4/+3
| | | | | | | |
| | * | | | | | refactor fair scheduler implementationAndrew xia2013-03-1613-194/+415
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 1.Chage "pool" properties to be the memeber of ActiveJob 2.Abstract the Schedulable of Pool and TaskSetManager 3.Abstract the FIFO and FS comparator algorithm 4.Miscellaneous changing of class define and construction
| | * | | | | | Removed some commented codeHarold Lim2013-03-121-3/+3
| | | | | | | |
| | * | | | | | Cleaned up the codeHarold Lim2013-03-121-28/+1
| | | | | | | |
| | * | | | | | Updated/Refactored the Fair Task Scheduler. It does not inherit ↵Harold Lim2013-03-128-488/+312
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | ClusterScheduler anymore. Rather, ClusterScheduler internally uses TaskSetQueuesManager that handles the scheduling of taskset queues. This is the class that should be extended to support other scheduling policies
| | * | | | | | Changed the name of the system property to set the allocation xmlHarold Lim2013-03-121-1/+1
| | | | | | | |
| | * | | | | | Made changes to the SparkContext to have a DynamicVariable for setting local ↵Harold Lim2013-03-127-29/+530
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | properties that can be passed down the stack. Added an implementation of the fair scheduler
| * | | | | | | Fixed a stupid mistake that NonJavaSerializableClass was made JavaReynold Xin2013-05-241-1/+1
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | serializable.
| * | | | | | | Automatically configure Netty port. This makes unit tests usingReynold Xin2013-05-2410-112/+129
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | local-cluster pass. Previously they were failing because Netty was trying to bind to the same port for all processes. Pair programmed with @shivaram.
| * | | | | | | Fixed the bug that shuffle serializer is ignored by the new shuffleReynold Xin2013-05-242-4/+19
| | |_|/ / / / | |/| | | | | | | | | | | | | | | | | | | block iterators for local blocks. Also added a unit test for that.
| * | | | | | Merge pull request #619 from woggling/adjust-samplingMatei Zaharia2013-05-211-1/+1
| |\ \ \ \ \ \ | | | | | | | | | | | | | | | | Use ARRAY_SAMPLE_SIZE constant instead of hard-coded 100.0 in SizeEstimator
| | * | | | | | Use ARRAY_SAMPLE_SIZE constant instead of 100.0Charles Reiss2013-05-211-1/+1
| | | | | | | |
| * | | | | | | DistributedSuite: remove dead test codeCharles Reiss2013-05-211-1/+0
| |/ / / / / /
| * | | | | | Merge pull request #610 from JoshRosen/spark-747Reynold Xin2013-05-174-0/+26
| |\ \ \ \ \ \ | | | | | | | | | | | | | | | | Throw exception if TaskResult exceeds Akka frame size
| | * | | | | | Abort job if result exceeds Akka frame size; add test.Josh Rosen2013-05-164-1/+23
| | | | | | | |
| | * | | | | | Throw exception if task result exceeds Akka frame size.Josh Rosen2013-05-111-0/+4
| | | |_|_|/ / | | |/| | | | | | | | | | | | | | | | | | This partially addresses SPARK-747.
| * | | | | | Changed the logging level from info to warning when addJar(null) isReynold Xin2013-05-171-9/+10
| | | | | | | | | | | | | | | | | | | | | | | | | | | | called.
| * | | | | | Merge branch 'master' of github.com:mesos/sparkReynold Xin2013-05-171-0/+4
| |\ \ \ \ \ \ | | | |_|/ / / | | |/| | | |
| | * | | | | Added dependency on netty-all in Maven.Reynold Xin2013-05-161-0/+4
| | | | | | |
| * | | | | | Hope this does not turn into a bike shed changeMridul Muralidharan2013-05-171-2/+4
| | | | | | |
| * | | | | | Filter out nulls - prevent NPEMridul Muralidharan2013-05-161-0/+2
| |/ / / / /
| * | | | | Merge pull request #602 from rxin/shufflemergeMatei Zaharia2013-05-1523-440/+1258
| |\ \ \ \ \ | | | | | | | | | | | | | | Manual merge & cleanup of Shane's Shuffle Performance Optimization
| | * \ \ \ \ Merge branch 'master' of github.com:mesos/spark into shufflemergeReynold Xin2013-05-1528-178/+585
| | |\ \ \ \ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Conflicts: core/src/main/scala/spark/storage/BlockManager.scala core/src/test/scala/spark/DistributedSuite.scala project/SparkBuild.scala
| | * | | | | | Added test for Netty suite.Reynold Xin2013-05-072-1/+19
| | | | | | | |
| | * | | | | | Cleaned up connection manager (moved many classes to their own files).Reynold Xin2013-05-077-252/+315
| | | | | | | |
| | * | | | | | Minor style fix in DiskStore...Reynold Xin2013-05-071-2/+2
| | | | | | | |
| | * | | | | | Cleaned up Scala files in network/netty from Shane's PR.Reynold Xin2013-05-072-33/+35
| | | | | | | |
| | * | | | | | Cleaned up the Java files from Shane's PR.Reynold Xin2013-05-078-118/+85
| | | | | | | |
| | * | | | | | Cleaned up BlockManager and BlockFetcherIterator from Shane's PR.Reynold Xin2013-05-073-99/+102
| | | | | | | |
| | * | | | | | Moved BlockFetcherIterator to its own file.Reynold Xin2013-05-072-339/+362
| | | | | | | |
| | * | | | | | Merge branch 'shuffle-performance-fix-0.7' of github.com:shane-huang/spark ↵Reynold Xin2013-05-0712-68/+808
| | |\ \ \ \ \ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | into shufflemerge Conflicts: core/src/main/scala/spark/storage/BlockManager.scala core/src/main/scala/spark/storage/DiskStore.scala project/SparkBuild.scala
| | | * | | | | | fix a bug in netty Block Fetchershane-huang2013-04-163-37/+37
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Signed-off-by: shane-huang <shengsheng.huang@intel.com>
| | | * | | | | | Shuffle Performance fix: Use netty embeded OIO file server instead of ↵shane-huang2013-04-0712-54/+792
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 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>
| * | | | | | | | Merge pull request #593 from squito/driver_ui_linkReynold Xin2013-05-157-13/+21
| |\ \ \ \ \ \ \ \ | | |_|_|/ / / / / | |/| | | | | | | Master UI has link to Application UI