Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Fixed bug in CheckpointRDD to prevent exception when the original RDD had ↵ | Tathagata Das | 2013-02-10 | 2 | -2/+12 |
| | | | | zero splits. | ||||
* | Merge pull request #450 from stephenh/inlinemergepair | Matei Zaharia | 2013-02-05 | 1 | -6/+4 |
|\ | | | | | Inline mergePair to look more like the narrow dep branch. | ||||
| * | Inline mergePair to look more like the narrow dep branch. | Stephen Haberman | 2013-02-05 | 1 | -6/+4 |
| | | | | | | | | | | | | | | No functionality changes, I think this is just more consistent given mergePair isn't called multiple times/recursive. Also added a comment to explain the usual case of having two parent RDDs. | ||||
* | | Merge branch 'master' into fixdeathpactexception | Stephen Haberman | 2013-02-05 | 23 | -237/+965 |
|\ \ | | | | | | | | | | | | | Conflicts: core/src/main/scala/spark/deploy/worker/Worker.scala | ||||
| * \ | Merge pull request #449 from stephenh/longerdriversuite | Matei Zaharia | 2013-02-05 | 1 | -1/+2 |
| |\ \ | | | | | | | | | Increase DriverSuite timeout. | ||||
| | * | | Increase DriverSuite timeout. | Stephen Haberman | 2013-02-05 | 1 | -1/+2 |
| | |/ | |||||
| * | | Small fix to test for distinct | Matei Zaharia | 2013-02-04 | 1 | -1/+1 |
| | | | |||||
| * | | Fix failing test | Matei Zaharia | 2013-02-04 | 1 | -2/+1 |
| | | | |||||
| * | | Merge pull request #445 from JoshRosen/pyspark_fixes | Matei Zaharia | 2013-02-03 | 1 | -2/+9 |
| |\ \ | | | | | | | | | Fix exit status in PySpark unit tests; fix/optimize PySpark's RDD.take() | ||||
| | * | | Fetch fewer objects in PySpark's take() method. | Josh Rosen | 2013-02-03 | 1 | -2/+9 |
| | |/ | |||||
| * | | Merge pull request #379 from stephenh/sparkmem | Matei Zaharia | 2013-02-02 | 6 | -35/+17 |
| |\ \ | | | | | | | | | Add spark.executor.memory to differentiate executor memory from spark-shell | ||||
| | * | | Fix dangling old variable names. | Stephen Haberman | 2013-02-02 | 1 | -2/+2 |
| | | | | |||||
| | * | | Move executorMemory up into SchedulerBackend. | Stephen Haberman | 2013-02-02 | 4 | -29/+12 |
| | | | | |||||
| | * | | Merge branch 'master' into sparkmem | Stephen Haberman | 2013-02-02 | 136 | -1920/+3738 |
| | |\| | |||||
| | * | | Fix SPARK_MEM in ExecutorRunner. | Stephen Haberman | 2013-01-22 | 1 | -1/+1 |
| | | | | |||||
| | * | | Restore SPARK_MEM in executorEnvs. | Stephen Haberman | 2013-01-22 | 1 | -2/+3 |
| | | | | |||||
| | * | | Add spark.executor.memory to differentiate executor memory from spark-shell ↵ | Stephen Haberman | 2013-01-15 | 3 | -10/+8 |
| | | | | | | | | | | | | | | | | memory. | ||||
| * | | | Merge pull request #422 from squito/blockmanager_info | Matei Zaharia | 2013-02-02 | 6 | -38/+59 |
| |\ \ \ | | | | | | | | | | | RDDInfo available from SparkContext | ||||
| | * | | | remove unneeded (and unused) filter on block info | Imran Rashid | 2013-02-01 | 1 | -2/+0 |
| | | | | | |||||
| | * | | | track total partitions, in addition to cached partitions; use scala string ↵ | Imran Rashid | 2013-02-01 | 3 | -9/+13 |
| | | | | | | | | | | | | | | | | | | | | formatting | ||||
| | * | | | fixup merge (master -> driver renaming) | Imran Rashid | 2013-02-01 | 1 | -1/+1 |
| | | | | | |||||
| | * | | | Merge branch 'master' into blockmanager_info | Imran Rashid | 2013-01-30 | 30 | -227/+264 |
| | |\ \ \ | | | | | | | | | | | | | | | | | | | | | | | | | Conflicts: core/src/main/scala/spark/storage/BlockManagerMaster.scala | ||||
| | * | | | | rename Slaves --> Executor | Imran Rashid | 2013-01-30 | 2 | -5/+5 |
| | | | | | | |||||
| | * | | | | Merge branch 'master' into blockmanager_info | Imran Rashid | 2013-01-29 | 21 | -187/+202 |
| | |\ \ \ \ | |||||
| | * | | | | | better formatting for RDDInfo | Imran Rashid | 2013-01-28 | 1 | -3/+9 |
| | | | | | | | |||||
| | * | | | | | expose RDD & storage info directly via SparkContext | Imran Rashid | 2013-01-28 | 4 | -28/+41 |
| | | | | | | | |||||
| * | | | | | | Merge pull request #436 from stephenh/removeextraloop | Matei Zaharia | 2013-02-02 | 1 | -13/+10 |
| |\ \ \ \ \ \ | | | | | | | | | | | | | | | | | Once we find a split with no block, we don't have to look for more. | ||||
| | * | | | | | | Further simplify checking for Nil. | Stephen Haberman | 2013-02-02 | 1 | -3/+1 |
| | | | | | | | | |||||
| | * | | | | | | Once we find a split with no block, we don't have to look for more. | Stephen Haberman | 2013-01-31 | 1 | -12/+11 |
| | | |_|/ / / | | |/| | | | | |||||
| * | | | | | | Merge pull request #442 from stephenh/fixsystemnames | Matei Zaharia | 2013-02-02 | 6 | -73/+68 |
| |\ \ \ \ \ \ | | | | | | | | | | | | | | | | | Fix createActorSystem not actually using the systemName parameter. | ||||
| | * | | | | | | Fix createActorSystem not actually using the systemName parameter. | Stephen Haberman | 2013-02-02 | 6 | -73/+68 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | This meant all system names were "spark", which worked, but didn't lead to the most intuitive log output. This fixes createActorSystem to use the passed system name, and refactors Master/Worker to encapsulate their system/actor names instead of having the clients guess at them. Note that the driver system name, "spark", is left as is, and is still repeated a few times, but that seems like a separate issue. | ||||
| * | | | | | | | Formatting | Matei Zaharia | 2013-02-02 | 1 | -1/+2 |
| | | | | | | | | |||||
| * | | | | | | | Formatting | Matei Zaharia | 2013-02-02 | 1 | -6/+9 |
| | | | | | | | | |||||
| * | | | | | | | Merge remote-tracking branch 'base/master' into dag-sched-tests | Charles Reiss | 2013-02-02 | 50 | -395/+504 |
| |\ \ \ \ \ \ \ | | | |_|_|_|_|/ | | |/| | | | | | | | | | | | | | | | | | | | | | Conflicts: core/src/main/scala/spark/scheduler/DAGScheduler.scala | ||||
| * | | | | | | | Code review changes: add sc.stop; style of multiline comments; parens on ↵ | Charles Reiss | 2013-02-01 | 1 | -22/+47 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | procedure calls. | ||||
| * | | | | | | | Comment at top of DAGSchedulerSuite | Charles Reiss | 2013-01-30 | 1 | -1/+14 |
| | | | | | | | | |||||
| * | | | | | | | Change DAGSchedulerSuite to run DAGScheduler in the same Thread. | Charles Reiss | 2013-01-30 | 1 | -249/+319 |
| | | | | | | | | |||||
| * | | | | | | | Refactor DAGScheduler more to allow testing without a separate thread. | Charles Reiss | 2013-01-30 | 1 | -65/+111 |
| | | | | | | | | |||||
| * | | | | | | | Clear spark.master.port to cleanup for other tests | Charles Reiss | 2013-01-29 | 1 | -0/+1 |
| | | | | | | | | |||||
| * | | | | | | | Add DAGScheduler tests. | Charles Reiss | 2013-01-29 | 1 | -0/+540 |
| | | | | | | | | |||||
| * | | | | | | | Refactoring to DAGScheduler to aid testing | Charles Reiss | 2013-01-29 | 2 | -12/+18 |
| | | | | | | | | |||||
| * | | | | | | | Add easymock to POMs | Charles Reiss | 2013-01-29 | 1 | -0/+5 |
| | |_|_|_|/ / | |/| | | | | | |||||
* | | | | | | | Handle Terminated to avoid endless DeathPactExceptions. | Stephen Haberman | 2013-02-05 | 2 | -19/+13 |
| |/ / / / / |/| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Credit to Roland Kuhn, Akka's tech lead, for pointing out this various obvious fix, but StandaloneExecutorBackend.preStart's catch block would never (ever) get hit, because all of the operation's in preStart are async. So, the System.exit in the catch block was skipped, and instead Akka was sending Terminated messages which, since we didn't handle, it turned into DeathPactException, which started a postRestart/preStart infinite loop. | ||||
* | | | | | | Add back test for distinct without parens | Matei Zaharia | 2013-02-01 | 1 | -1/+2 |
| | | | | | | |||||
* | | | | | | Reduce the amount of duplicate logging Akka does to stdout. | Stephen Haberman | 2013-02-01 | 1 | -0/+1 |
| |/ / / / |/| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Given we have Akka logging go through SLF4j to log4j, we don't need all the extra noise of Akka's stdout logger that is supposedly only used during Akka init time but seems to continue logging lots of noisy network events that we either don't care about or are in the log4j logs anyway. See: http://doc.akka.io/docs/akka/2.0/general/configuration.html # Log level for the very basic logger activated during AkkaApplication startup # Options: ERROR, WARNING, INFO, DEBUG # stdout-loglevel = "WARNING" | ||||
* | | | | | Reduced the memory usage of reduce and similar operations | Matei Zaharia | 2013-02-01 | 9 | -46/+107 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | These operations used to wait for all the results to be available in an array on the driver program before merging them. They now merge values incrementally as they arrive. | ||||
* | | | | | Merge branch 'master' of github.com:mesos/spark | Matei Zaharia | 2013-02-01 | 8 | -59/+49 |
|\ \ \ \ \ | |||||
| * \ \ \ \ | Merge pull request #432 from stephenh/moreprivacy | Matei Zaharia | 2013-02-01 | 8 | -59/+49 |
| |\ \ \ \ \ | | | | | | | | | | | | | | | Add more private declarations. | ||||
| | * | | | | | Add more private declarations. | Stephen Haberman | 2013-01-31 | 8 | -59/+49 |
| | | |/ / / | | |/| | | | |||||
* | / | | | | formatting | Matei Zaharia | 2013-02-01 | 2 | -3/+3 |
|/ / / / / |