Merge pull request #32 from mridulm/master Address review comments, move to incubator spark
Also includes a small fix to speculative execution. <edit> Continued from https://github.com/mesos/spark/pull/914 </edit> Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/d6ead478 Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/d6ead478 Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/d6ead478 Branch: refs/heads/master Commit: d6ead478094b3eb02823e7e8b06a16c3989c7f0c Parents: 8f11c36 b5025d9 Author: Matei Zaharia <ma...@eecs.berkeley.edu> Authored: Fri Oct 11 15:43:01 2013 -0700 Committer: Matei Zaharia <ma...@eecs.berkeley.edu> Committed: Fri Oct 11 15:43:01 2013 -0700 ---------------------------------------------------------------------- .../org/apache/spark/MapOutputTracker.scala | 4 +- .../scala/org/apache/spark/SparkContext.scala | 8 +++- .../spark/broadcast/BitTorrentBroadcast.scala | 4 +- .../apache/spark/broadcast/HttpBroadcast.scala | 8 ++-- .../apache/spark/broadcast/TreeBroadcast.scala | 4 +- .../spark/network/netty/ShuffleSender.scala | 3 +- .../apache/spark/scheduler/DAGScheduler.scala | 4 +- .../org/apache/spark/scheduler/ResultTask.scala | 4 +- .../apache/spark/scheduler/ShuffleMapTask.scala | 4 +- .../cluster/ClusterTaskSetManager.scala | 4 +- .../org/apache/spark/storage/BlockManager.scala | 39 +++++++++++++++++--- .../org/apache/spark/util/MetadataCleaner.scala | 36 ++++++++++++++++-- 12 files changed, 93 insertions(+), 29 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/d6ead478/core/src/main/scala/org/apache/spark/SparkContext.scala ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/d6ead478/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/d6ead478/core/src/main/scala/org/apache/spark/storage/BlockManager.scala ----------------------------------------------------------------------
