-
- Downloads
[SPARK-9144] Remove DAGScheduler.runLocallyWithinThread and spark.localExecution.enabled
Spark has an option called spark.localExecution.enabled; according to the docs: > Enables Spark to run certain jobs, such as first() or take() on the driver, without sending tasks to the cluster. This can make certain jobs execute very quickly, but may require shipping a whole partition of data to the driver. This feature ends up adding quite a bit of complexity to DAGScheduler, especially in the runLocallyWithinThread method, but as far as I know nobody uses this feature (I searched the mailing list and haven't seen any recent mentions of the configuration nor stacktraces including the runLocally method). As a step towards scheduler complexity reduction, I propose that we remove this feature and all code related to it for Spark 1.5. This pull request simply brings #7484 up to date. Author: Josh Rosen <joshrosen@databricks.com> Author: Reynold Xin <rxin@databricks.com> Closes #7585 from rxin/remove-local-exec and squashes the following commits: 84bd10e [Reynold Xin] Python fix. 1d9739a [Reynold Xin] Merge pull request #7484 from JoshRosen/remove-localexecution eec39fa [Josh Rosen] Remove allowLocal(); deprecate user-facing uses of it. b0835dc [Josh Rosen] Remove local execution code in DAGScheduler 8975d96 [Josh Rosen] Remove local execution tests. ffa8c9b [Josh Rosen] Remove documentation for configuration
Showing
- core/src/main/scala/org/apache/spark/SparkContext.scala 66 additions, 20 deletionscore/src/main/scala/org/apache/spark/SparkContext.scala
- core/src/main/scala/org/apache/spark/api/java/JavaRDDLike.scala 1 addition, 1 deletion...rc/main/scala/org/apache/spark/api/java/JavaRDDLike.scala
- core/src/main/scala/org/apache/spark/api/python/PythonRDD.scala 2 additions, 3 deletions...rc/main/scala/org/apache/spark/api/python/PythonRDD.scala
- core/src/main/scala/org/apache/spark/executor/Executor.scala 0 additions, 2 deletionscore/src/main/scala/org/apache/spark/executor/Executor.scala
- core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala 1 addition, 1 deletion...rc/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala
- core/src/main/scala/org/apache/spark/rdd/RDD.scala 2 additions, 2 deletionscore/src/main/scala/org/apache/spark/rdd/RDD.scala
- core/src/main/scala/org/apache/spark/rdd/ZippedWithIndexRDD.scala 1 addition, 2 deletions.../main/scala/org/apache/spark/rdd/ZippedWithIndexRDD.scala
- core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala 15 additions, 102 deletions.../main/scala/org/apache/spark/scheduler/DAGScheduler.scala
- core/src/main/scala/org/apache/spark/scheduler/DAGSchedulerEvent.scala 0 additions, 1 deletion.../scala/org/apache/spark/scheduler/DAGSchedulerEvent.scala
- core/src/test/scala/org/apache/spark/rdd/RDDSuite.scala 1 addition, 1 deletioncore/src/test/scala/org/apache/spark/rdd/RDDSuite.scala
- core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala 10 additions, 73 deletions.../scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala
- core/src/test/scala/org/apache/spark/scheduler/OutputCommitCoordinatorSuite.scala 2 additions, 2 deletions...apache/spark/scheduler/OutputCommitCoordinatorSuite.scala
- core/src/test/scala/org/apache/spark/scheduler/SparkListenerSuite.scala 1 addition, 1 deletion...scala/org/apache/spark/scheduler/SparkListenerSuite.scala
- docs/configuration.md 0 additions, 9 deletionsdocs/configuration.md
- external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala 1 addition, 2 deletions...ain/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala
- mllib/src/main/scala/org/apache/spark/mllib/rdd/SlidingRDD.scala 1 addition, 1 deletion...rc/main/scala/org/apache/spark/mllib/rdd/SlidingRDD.scala
- python/pyspark/context.py 1 addition, 2 deletionspython/pyspark/context.py
- python/pyspark/rdd.py 2 additions, 2 deletionspython/pyspark/rdd.py
- sql/core/src/main/scala/org/apache/spark/sql/execution/SparkPlan.scala 1 addition, 2 deletions...main/scala/org/apache/spark/sql/execution/SparkPlan.scala
Loading
Please register or sign in to comment