Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[SPARK-9144] Remove DAGScheduler.runLocallyWithinThread and spark.localExecution.enabled #7585

Closed
wants to merge 6 commits into from

Conversation

rxin
Copy link
Contributor

@rxin rxin commented Jul 22, 2015

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.

JoshRosen and others added 5 commits July 17, 2015 15:10
[SPARK-9144] Remove DAGScheduler.runLocallyWithinThread and spark.localExecution.enabled

Conflicts:
	core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
	core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala
@SparkQA
Copy link

SparkQA commented Jul 22, 2015

Test build #38040 has finished for PR 7585 at commit 1d9739a.

  • This patch fails PySpark unit tests.
  • This patch merges cleanly.
  • This patch adds no public classes.

@SparkQA
Copy link

SparkQA commented Jul 22, 2015

Test build #38100 has finished for PR 7585 at commit 84bd10e.

  • This patch fails Spark unit tests.
  • This patch merges cleanly.
  • This patch adds no public classes.

@rxin
Copy link
Contributor Author

rxin commented Jul 22, 2015

Jenkins, retest this please.

1 similar comment
@JoshRosen
Copy link
Contributor

Jenkins, retest this please.

@SparkQA
Copy link

SparkQA commented Jul 23, 2015

Test build #1181 has finished for PR 7585 at commit 84bd10e.

  • This patch fails Spark unit tests.
  • This patch merges cleanly.
  • This patch adds no public classes.

@SparkQA
Copy link

SparkQA commented Jul 23, 2015

Test build #38125 has finished for PR 7585 at commit 84bd10e.

  • This patch passes all tests.
  • This patch merges cleanly.
  • This patch adds no public classes.

@rxin
Copy link
Contributor Author

rxin commented Jul 23, 2015

I've merged this.

@asfgit asfgit closed this in b217230 Jul 23, 2015
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
3 participants