- Jan 06, 2013
-
-
Tathagata Das authored
-
- Jan 01, 2013
-
-
Tathagata Das authored
-
Tathagata Das authored
-
Tathagata Das authored
-
Matei Zaharia authored
Avoid stalls when computation of cached RDD throws exception
-
Matei Zaharia authored
Raise exception when hashing Java arrays (SPARK-597)
-
Charles Reiss authored
-
Charles Reiss authored
-
Charles Reiss authored
-
- Dec 31, 2012
-
-
Josh Rosen authored
-
- Dec 30, 2012
-
-
Tathagata Das authored
-
Tathagata Das authored
-
- Dec 29, 2012
-
-
Tathagata Das authored
Improved jekyll and scala docs. Made many classes and method private to remove them from scala docs.
-
Matei Zaharia authored
Fix deletion of files in current working directory by clearFiles()
-
- Dec 28, 2012
-
-
Josh Rosen authored
-
Josh Rosen authored
-
Josh Rosen authored
-
Josh Rosen authored
This fixes an issue where Spark could delete original files in the current working directory that were added to the job using addFile(). There was also the potential for addFile() to overwrite local files, which is addressed by changing Utils.fetchFile() to log a warning instead of overwriting a file with new contents. This is a short-term fix; a better long-term solution would be to remove the dependence on storing files in the current working directory, since we can't change the cwd from Java.
-
- Dec 27, 2012
-
-
Tathagata Das authored
Modifications to make sure LocalScheduler terminate cleanly without errors when SparkContext is shutdown, to minimize spurious exception during master failure tests.
-
- Dec 26, 2012
-
-
Tathagata Das authored
-
Tathagata Das authored
Conflicts: core/src/main/scala/spark/ParallelCollection.scala core/src/main/scala/spark/RDD.scala core/src/main/scala/spark/rdd/BlockRDD.scala core/src/main/scala/spark/rdd/CartesianRDD.scala core/src/main/scala/spark/rdd/CoGroupedRDD.scala core/src/main/scala/spark/rdd/CoalescedRDD.scala core/src/main/scala/spark/rdd/FilteredRDD.scala core/src/main/scala/spark/rdd/FlatMappedRDD.scala core/src/main/scala/spark/rdd/GlommedRDD.scala core/src/main/scala/spark/rdd/HadoopRDD.scala core/src/main/scala/spark/rdd/MapPartitionsRDD.scala core/src/main/scala/spark/rdd/MapPartitionsWithSplitRDD.scala core/src/main/scala/spark/rdd/MappedRDD.scala core/src/main/scala/spark/rdd/PipedRDD.scala core/src/main/scala/spark/rdd/SampledRDD.scala core/src/main/scala/spark/rdd/ShuffledRDD.scala core/src/main/scala/spark/rdd/UnionRDD.scala core/src/main/scala/spark/scheduler/ResultTask.scala core/src/test/scala/spark/CheckpointSuite.scala
-
- Dec 24, 2012
-
-
Matei Zaharia authored
lookup() needn't fail when there is no partitioner
-
Mark Hamstra authored
-
Matei Zaharia authored
Allow distinct() to be called without parentheses
-
Mark Hamstra authored
-
- Dec 21, 2012
-
-
Reynold Xin authored
-
Reynold Xin authored
-
Reynold Xin authored
-
Matei Zaharia authored
Kryo2 update against Spark master
-
- Dec 20, 2012
-
-
Reynold Xin authored
Conflicts: core/src/main/scala/spark/MapOutputTracker.scala core/src/main/scala/spark/PairRDDFunctions.scala core/src/main/scala/spark/ParallelCollection.scala core/src/main/scala/spark/RDD.scala core/src/main/scala/spark/rdd/BlockRDD.scala core/src/main/scala/spark/rdd/CartesianRDD.scala core/src/main/scala/spark/rdd/CoGroupedRDD.scala core/src/main/scala/spark/rdd/CoalescedRDD.scala core/src/main/scala/spark/rdd/FilteredRDD.scala core/src/main/scala/spark/rdd/FlatMappedRDD.scala core/src/main/scala/spark/rdd/GlommedRDD.scala core/src/main/scala/spark/rdd/HadoopRDD.scala core/src/main/scala/spark/rdd/MapPartitionsRDD.scala core/src/main/scala/spark/rdd/MapPartitionsWithSplitRDD.scala core/src/main/scala/spark/rdd/MappedRDD.scala core/src/main/scala/spark/rdd/PipedRDD.scala core/src/main/scala/spark/rdd/SampledRDD.scala core/src/main/scala/spark/rdd/ShuffledRDD.scala core/src/main/scala/spark/rdd/UnionRDD.scala core/src/main/scala/spark/storage/BlockManager.scala core/src/main/scala/spark/storage/BlockManagerId.scala core/src/main/scala/spark/storage/BlockManagerMaster.scala core/src/main/scala/spark/storage/StorageLevel.scala core/src/main/scala/spark/util/MetadataCleaner.scala core/src/main/scala/spark/util/TimeStampedHashMap.scala core/src/test/scala/spark/storage/BlockManagerSuite.scala run
-
Tathagata Das authored
Conflicts: core/src/main/scala/spark/ParallelCollection.scala core/src/test/scala/spark/CheckpointSuite.scala streaming/src/main/scala/spark/streaming/DStream.scala
-
Tathagata Das authored
-
Tathagata Das authored
-
Matei Zaharia authored
Added the ability in block manager to remove blocks.
-
Reynold Xin authored
-
- Dec 19, 2012
-
-
Matei Zaharia authored
SPARK-616: Logging dead workers in Web UI.
-
Reynold Xin authored
excessive debug messages.
-
Matei Zaharia authored
Tweaked debian packaging to be a bit more in line with debian standards
-
Thomas Dudziak authored
-
- Dec 18, 2012
-
-
Matei Zaharia authored
Fixed repl maven build
-