aboutsummaryrefslogtreecommitdiff
path: root/core
Commit message (Collapse)AuthorAgeFilesLines
* Adding Sonatype releases to SBT.Patrick Wendell2012-10-071-0/+0
| | | | | | | | | | This does a few things to get this branch ready for release: 1. Upgrades the sbt and Scala version 2. Sets the release number to 0.5.1 3. Adds the Sonatype publishing target 4. Installs the PGP signing plugin 5. Removes the Mesos jar dependency
* Make reduce logging less verboseMatei Zaharia2012-10-061-3/+4
|
* Merge branch 'master' into reduce-loggingMatei Zaharia2012-10-053-13/+30
|\
| * Merge branch 'master' of github.com:mesos/sparkMatei Zaharia2012-10-052-12/+29
| |\
| | * Fix SizeEstimator tests to work with String classes in JDK 6 and 7Shivaram Venkataraman2012-10-042-12/+29
| | |
| * | Only group elements ten at a time into SequenceFile records inMatei Zaharia2012-10-041-1/+1
| |/ | | | | | | saveAsObjectFile
* | Let the reducer retry if a fetch fails before reading all recordsMatei Zaharia2012-10-043-22/+43
| |
* | Add more logging for number of records fetched by each reduceMatei Zaharia2012-10-041-1/+6
|/
* Backport sampling fixes from dev (suggested by Henry Milner)Matei Zaharia2012-09-294-42/+51
|
* Make error reporting less scary if we can't look up UseCompressedOopsMatei Zaharia2012-09-281-10/+6
|
* Look for Kryo registrator using context class loaderMatei Zaharia2012-09-261-1/+2
|
* Fixed GrowableAccumulatorParam.zero() to do a copy and to make sure it'sMatei Zaharia2012-09-111-3/+13
| | | | empty instead of using the old initialValue
* Merge branch 'master' into collection_accumulatorsImran Rashid2012-09-114-6/+33
|\ | | | | | | | | Conflicts: core/src/test/scala/spark/AccumulatorSuite.scala
| * End runJob with a SparkException when a Mesos task fails too many timesMatei Zaharia2012-08-312-0/+4
| |
| * change tests to show utility of localValueImran Rashid2012-08-202-4/+5
| |
| * make accumulator.localValue public, add testsImran Rashid2012-08-142-1/+24
| |
* | fix stupid typo and add documentationImran Rashid2012-09-071-1/+7
| |
* | add accumulators for mutable collections, with correct typing!Imran Rashid2012-08-173-5/+46
|/
* Add test-cases for 32-bit and no-compressed oops scenarios.Shivaram Venkataraman2012-08-122-14/+46
|
* Move object size and pointer size initialization into a function to enable ↵Shivaram Venkataraman2012-08-121-21/+31
| | | | unit-testing
* Update test cases to match the new size estimates. Uses 64-bit and compressedShivaram Venkataraman2012-08-112-35/+77
| | | | oops setting to get deterministic results
* If spark.test.useCompressedOops is set, use that to infer compressed oopsShivaram Venkataraman2012-08-111-0/+3
| | | | setting. This is useful to get a deterministic test case
* Use HotSpotDiagnosticMXBean to get if CompressedOops are in use or notShivaram Venkataraman2012-08-111-3/+28
|
* Add link to Java wiki which specifies what changes with compressed oopsShivaram Venkataraman2012-08-111-0/+3
|
* Changes to make size estimator more accurate. Fixes object size, pointer sizeShivaram Venkataraman2012-08-111-4/+38
| | | | | according to architecture and also aligns objects and arrays when computing instance sizes. Verified using Eclipse Memory Analysis Tool (MAT)
* Made range partition balance tests more aggressive.Matei Zaharia2012-08-031-8/+8
| | | | | | This is because we pull out such a large sample (10x the number of partitions) that we should expect pretty good balance. The tests are also deterministic so there's no worry about them failing irreproducibly.
* Added a unit test for cross-partition balancing in sort, and changes toMatei Zaharia2012-08-033-41/+84
| | | | | RangePartitioner to make it pass. It turns out that the first partition was always kind of small due to how we picked partition boundaries.
* Fix to #154 (CacheTracker trying to cast a broadcast variable's ID to int)Matei Zaharia2012-08-031-3/+4
|
* Fix for partitioning when sorting in descending orderHarvey2012-08-031-2/+1
|
* Logging Throwables in Info and DebugPaul Cavallaro2012-07-301-2/+2
| | | | Logging Throwables in logInfo and logDebug instead of swallowing them.
* Merge pull request #145 from squito/exp_accumMatei Zaharia2012-07-264-13/+277
|\ | | | | add Accumulatable, add corresponding docs & tests for accumulators
| * tasks cannot access value of accumulatorImran Rashid2012-07-262-56/+21
| |
| * one more minor cleanup to scaladocImran Rashid2012-07-161-2/+2
| |
| * fix up scaladoc, naming of type parametersImran Rashid2012-07-162-15/+12
| |
| * rename addToAccum to addAccumulatorImran Rashid2012-07-162-4/+4
| |
| * add some functionality to Vector, delete copy in AccumulatorSuiteImran Rashid2012-07-122-113/+33
| |
| * move Vector class into core and spark.util packageImran Rashid2012-07-121-0/+84
| |
| * Accumulator now inherits from Accumulable, whcih simplifies a bunch of other ↵Imran Rashid2012-07-123-34/+56
| | | | | | | | things (eg., no +:=)
| * improve scaladocImran Rashid2012-07-121-1/+1
| |
| * add Accumulatable, add corresponding docs & tests for accumulatorsImran Rashid2012-07-123-0/+276
| |
* | Merge pull request #152 from dennybritz/fix/testbeforeafterMatei Zaharia2012-07-2312-109/+153
|\ \ | | | | | | Always destroy SparkContext in after block for the unit tests.
| * | Stlystic changesDenny2012-07-2311-22/+22
| | |
| * | Always destroy SparkContext in after block for the unit tests.Denny2012-07-1810-107/+151
| |/
* | Merge branch 'master' of github.com:mesos/sparkMatei Zaharia2012-07-212-6/+6
|\ \
| * \ Merge pull request #149 from dennybritz/serfixMatei Zaharia2012-07-212-6/+6
| |\ \ | | | | | | | | Instantiating custom serializer using user's classpath
| | * | Create the ClassLoader before creating a SparkEnv - SparkEnv must use the ↵Denny2012-07-171-5/+5
| | | | | | | | | | | | | | | | loader.
| | * | Use Context classloader for Serializer classDenny2012-07-171-1/+1
| | |/
* | | Fix a bug where an input path was added to a Hadoop job configuration twiceMatei Zaharia2012-07-211-4/+1
| | |
* | | Use full package name in importMatei Zaharia2012-07-211-1/+1
|/ /
* | Merge branch 'master' of github.com:mesos/sparkMatei Zaharia2012-07-122-5/+31
|\|