https://github.com/apache/spark

sort by:
Revision Author Date Message Commit Date
d1538eb Change version in REPL 07 October 2012, 17:40:29 UTC
f31b6f9 Changes to run script and README to deal with updated Scala version and with Mesos being in Maven 07 October 2012, 17:00:48 UTC
b97bde2 Merge pull request #252 from pwendell/0.5-with-sonatype Adding Sonatype releases to SBT. 07 October 2012, 16:47:46 UTC
14719b9 Adding Sonatype releases to SBT. 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 07 October 2012, 08:20:39 UTC
dbf1f3d Make reduce logging less verbose 07 October 2012, 00:10:09 UTC
7eae2d1 Merge branch 'master' into reduce-logging 05 October 2012, 23:36:16 UTC
d9bcc2a Merge branch 'master' of github.com:mesos/spark 05 October 2012, 23:35:48 UTC
1620d59 Merge pull request #246 from shivaram/size-estimator-fix-master Fix SizeEstimator tests to work with String classes in JDK 6 and 7 05 October 2012, 17:28:30 UTC
5975d2e Fix SizeEstimator tests to work with String classes in JDK 6 and 7 05 October 2012, 02:42:57 UTC
5a7b370 Only group elements ten at a time into SequenceFile records in saveAsObjectFile 04 October 2012, 23:49:30 UTC
66d7066 Let the reducer retry if a fetch fails before reading all records 04 October 2012, 23:41:17 UTC
588120c Add more logging for number of records fetched by each reduce 04 October 2012, 18:54:47 UTC
3d24281 Backport sampling fixes from dev (suggested by Henry Milner) 30 September 2012, 04:55:52 UTC
915ab97 Make error reporting less scary if we can't look up UseCompressedOops 28 September 2012, 21:52:37 UTC
a417cd4 Look for Kryo registrator using context class loader 26 September 2012, 21:14:17 UTC
2498f95 Fixed GrowableAccumulatorParam.zero() to do a copy and to make sure it's empty instead of using the old initialValue 11 September 2012, 22:17:44 UTC
66e5362 Merge pull request #175 from squito/collection_accumulators add accumulators for mutable collections, with correct typing! 11 September 2012, 21:29:10 UTC
1490d09 Merge branch 'master' into collection_accumulators Conflicts: core/src/test/scala/spark/AccumulatorSuite.scala 11 September 2012, 18:20:56 UTC
f8f125e fix stupid typo and add documentation 07 September 2012, 20:58:46 UTC
607b8ff End runJob with a SparkException when a Mesos task fails too many times 31 August 2012, 18:40:12 UTC
62e5326 Wording 30 August 2012, 15:37:43 UTC
e8ac922 Update sbt build command to create JARs 30 August 2012, 15:36:39 UTC
84bf792 Made region used by spark-ec2 configurable. 29 August 2012, 05:40:48 UTC
79c82b6 Merge pull request #173 from squito/accum_localValue make accumulator.localValue public, add tests 22 August 2012, 07:11:21 UTC
4d2efe9 change tests to show utility of localValue 20 August 2012, 22:17:31 UTC
823878c add accumulators for mutable collections, with correct typing! 17 August 2012, 22:52:42 UTC
206a383 make accumulator.localValue public, add tests 14 August 2012, 21:08:22 UTC
680df96 Merge pull request #169 from shivaram/master Changes to SizeEstimator more accurate 13 August 2012, 05:29:11 UTC
2ee7312 Add test-cases for 32-bit and no-compressed oops scenarios. 13 August 2012, 00:18:01 UTC
5450223 Move object size and pointer size initialization into a function to enable unit-testing 13 August 2012, 00:16:27 UTC
73452cc Update test cases to match the new size estimates. Uses 64-bit and compressed oops setting to get deterministic results 11 August 2012, 23:42:35 UTC
64b8fd6 If spark.test.useCompressedOops is set, use that to infer compressed oops setting. This is useful to get a deterministic test case 11 August 2012, 23:40:33 UTC
c0e773a Use HotSpotDiagnosticMXBean to get if CompressedOops are in use or not 11 August 2012, 21:38:05 UTC
f2475ca Add link to Java wiki which specifies what changes with compressed oops 11 August 2012, 09:34:20 UTC
980585b Changes to make size estimator more accurate. Fixes object size, pointer size according to architecture and also aligns objects and arrays when computing instance sizes. Verified using Eclipse Memory Analysis Tool (MAT) 11 August 2012, 09:18:39 UTC
1c5ae3e Merge pull request #151 from dennybritz/fix/examples_jar Examples ship to to cluster 05 August 2012, 00:39:41 UTC
38d86d2 updated readme 04 August 2012, 23:58:47 UTC
48cac41 Renamed EXAMPLES_JAR to SPARK_EXAMPLES_JAR 04 August 2012, 23:56:32 UTC
63c2020 Merge branch 'master' into fix/examples_jar 04 August 2012, 23:55:18 UTC
abca699 Made range partition balance tests more aggressive. 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. 03 August 2012, 20:44:17 UTC
6da2bcd Added a unit test for cross-partition balancing in sort, and changes to RangePartitioner to make it pass. It turns out that the first partition was always kind of small due to how we picked partition boundaries. 03 August 2012, 20:37:35 UTC
508221b Fix to #154 (CacheTracker trying to cast a broadcast variable's ID to int) 03 August 2012, 19:57:43 UTC
c0d5bd6 Merge pull request #164 from HarveyFeng/master Bug fix in RangePartitioner for partitioning when sorting in descending order. 03 August 2012, 19:27:17 UTC
5ec1332 Fix for partitioning when sorting in descending order 03 August 2012, 19:22:07 UTC
4a9c589 Merge pull request #157 from paulcavallaro/log-throwables Logging Throwables in Info and Debug 02 August 2012, 13:26:06 UTC
e3952f3 Logging Throwables in Info and Debug Logging Throwables in logInfo and logDebug instead of swallowing them. 30 July 2012, 17:41:09 UTC
1e2df26 Merge pull request #145 from squito/exp_accum add Accumulatable, add corresponding docs & tests for accumulators 27 July 2012, 00:25:45 UTC
0384be3 tasks cannot access value of accumulator 26 July 2012, 19:38:51 UTC
da42981 Merge pull request #152 from dennybritz/fix/testbeforeafter Always destroy SparkContext in after block for the unit tests. 23 July 2012, 23:13:24 UTC
5656dcd Stlystic changes 23 July 2012, 17:36:52 UTC
840e1b2 Merge branch 'master' of github.com:mesos/spark 22 July 2012, 04:58:40 UTC
6f44c0d Fix a bug where an input path was added to a Hadoop job configuration twice 22 July 2012, 04:58:28 UTC
d1759c0 Merge pull request #149 from dennybritz/serfix Instantiating custom serializer using user's classpath 22 July 2012, 04:54:50 UTC
5122f11 Use full package name in import 22 July 2012, 04:53:38 UTC
5559608 Always destroy SparkContext in after block for the unit tests. 18 July 2012, 20:09:50 UTC
e4dbaf6 syntax errors 18 July 2012, 19:18:00 UTC
1d98884 Use extended constructor in the examples. 18 July 2012, 18:46:03 UTC
2132c54 Create the ClassLoader before creating a SparkEnv - SparkEnv must use the loader. 17 July 2012, 21:05:26 UTC
2b84b50 Use Context classloader for Serializer class 17 July 2012, 20:55:23 UTC
7f43ba7 one more minor cleanup to scaladoc 17 July 2012, 01:26:48 UTC
913d42c fix up scaladoc, naming of type parameters 17 July 2012, 01:25:15 UTC
85940a7 rename addToAccum to addAccumulator 17 July 2012, 01:17:13 UTC
a33ca69 Merge branch 'master' of github.com:mesos/spark 13 July 2012, 01:38:20 UTC
452330e Allow null keys in Spark's reduce and group by 13 July 2012, 01:37:37 UTC
86024ca add some functionality to Vector, delete copy in AccumulatorSuite 12 July 2012, 20:08:03 UTC
42ce879 move Vector class into core and spark.util package 12 July 2012, 20:08:03 UTC
13cc72c Accumulator now inherits from Accumulable, whcih simplifies a bunch of other things (eg., no +:=) 12 July 2012, 19:40:10 UTC
7393562 improve scaladoc 12 July 2012, 16:58:06 UTC
30480e6 add Accumulatable, add corresponding docs & tests for accumulators 12 July 2012, 16:37:42 UTC
4259d37 Formatting 10 July 2012, 18:16:34 UTC
6980b67 Added more methods for loading/saving with new Hadoop API 10 July 2012, 18:11:35 UTC
cbe8846 Merge pull request #142 from rrmckinley/patch-1 Scalacheck groupId has changed https://github.com/rickynils/scalacheck/i... 29 June 2012, 23:40:57 UTC
3a326c0 Increase the default wait time for EC2 clusters to 2 minutes. 29 June 2012, 23:25:06 UTC
25972b5 Scalacheck groupId has changed https://github.com/rickynils/scalacheck/issues/24. Necessary to build with scalaVersion 2.9.2. Works with 2.9.1 too. 29 June 2012, 19:00:23 UTC
800fcbf Revert "Fixed HttpBroadcast to work with this branch's Serializer." This reverts commit b3eeac55b8f3c8c7b5ea18281d9d39dab63d5164. 17 June 2012, 21:29:39 UTC
94d77f8 Revert "Merge branch 'master' into dev" This reverts commit f58da6164eaf13dd986a39a40535975096b71b44, reversing changes made to 4449eb97834ed6191dc0937d255c475191895980. 17 June 2012, 21:27:45 UTC
f46e867 Revert "Update version number for dev branch" This reverts commit 08579ffa11574f3d53ef62ae1b41847b4dce16d5. 17 June 2012, 21:27:32 UTC
0e84d62 Revert "Various fixes to get unit tests running. In particular, shut down" This reverts commit 2893b305501a0e04cabdaa2fbad06ef86076cdf8. 17 June 2012, 21:27:30 UTC
4749ec0 Revert "Fixed nasty corner case bug in ByteBufferInputStream. Could not add a test case for this as I could not figure out how to deterministically reproduce the bug in a short testcase." This reverts commit 40536e3668c3f8077c91170318f3bbd8f3060517. 17 June 2012, 21:27:18 UTC
40536e3 Fixed nasty corner case bug in ByteBufferInputStream. Could not add a test case for this as I could not figure out how to deterministically reproduce the bug in a short testcase. 17 June 2012, 20:28:41 UTC
2893b30 Various fixes to get unit tests running. In particular, shut down ConnectionManager and DAGScheduler properly, plus a fix to LocalScheduler that was not merged in from 0.5 and was actually caught by one of the tests. 17 June 2012, 07:28:45 UTC
08579ff Update version number for dev branch 16 June 2012, 06:55:43 UTC
b3eeac5 Fixed HttpBroadcast to work with this branch's Serializer. 16 June 2012, 06:54:38 UTC
f58da61 Merge branch 'master' into dev 16 June 2012, 06:47:11 UTC
b5cf47c Merge branch 'dev' of github.com:mesos/spark into dev 16 June 2012, 06:36:30 UTC
4449eb9 Changed version in master branch to 0.5.1-SNAPSHOT for further development. 14 June 2012, 02:26:14 UTC
5f54bdf Added shutdown for akka to SparkContext.stop(). Helps a little, but many testsuites still fail. 14 June 2012, 00:49:00 UTC
c6156da Multiple bug fixes to pass the testsuites ShuffleSuite and BlockManagerSuite. 13 June 2012, 20:26:49 UTC
0472cf8 Update version in SBT 12 June 2012, 18:30:49 UTC
4971e0f Updated version number to 0.5.0 12 June 2012, 17:41:57 UTC
08c50ad Added script for launching Spark on EC2 from Mesos, to make it easier for new users to get up and running on EC2. 11 June 2012, 06:06:15 UTC
879bc0b Merge branch 'master' into mesos-0.9 09 June 2012, 23:24:16 UTC
4b05798 Further bug fix to HttpBroadcast 09 June 2012, 23:24:03 UTC
587a16a Merge branch 'master' into mesos-0.9 09 June 2012, 23:17:07 UTC
8ed6628 Bug fix to HttpBroadcast 09 June 2012, 23:16:55 UTC
2fd9f99 Merge branch 'master' into mesos-0.9 09 June 2012, 22:58:35 UTC
e75b1b5 Change the default broadcast implementation to a simple HTTP-based broadcast. Fixes #139. 09 June 2012, 22:58:07 UTC
a96558c Performance improvements to shuffle operations: in particular, preserve RDD partitioning in more cases where it's possible, and use iterators instead of materializing collections when doing joins. 09 June 2012, 21:44:18 UTC
8b0bd5d Update SBT to version 0.11.3-2. 08 June 2012, 06:05:58 UTC
c2c7299 Added BlockManagerSuite, which I'd forgotten to merge. 07 June 2012, 20:47:10 UTC
back to top