You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by pw...@apache.org on 2015/04/29 08:18:51 UTC
spark git commit: Revert "[MINOR] [CORE] Warn users who try to cache
RDDs with dynamic allocation on."
Repository: spark
Updated Branches:
refs/heads/branch-1.2 d2080477d -> 6fd74d87c
Revert "[MINOR] [CORE] Warn users who try to cache RDDs with dynamic allocation on."
This reverts commit d2080477dcbf012bdb643ceb8b64faa7ed48aeb3.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/6fd74d87
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/6fd74d87
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/6fd74d87
Branch: refs/heads/branch-1.2
Commit: 6fd74d87c2898337f34d7fd75b1073fb6add07f9
Parents: d208047
Author: Patrick Wendell <pa...@databricks.com>
Authored: Tue Apr 28 23:20:51 2015 -0700
Committer: Patrick Wendell <pa...@databricks.com>
Committed: Tue Apr 28 23:20:51 2015 -0700
----------------------------------------------------------------------
core/src/main/scala/org/apache/spark/SparkContext.scala | 5 -----
1 file changed, 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/6fd74d87/core/src/main/scala/org/apache/spark/SparkContext.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/SparkContext.scala b/core/src/main/scala/org/apache/spark/SparkContext.scala
index 4e72eca..e9b4115 100644
--- a/core/src/main/scala/org/apache/spark/SparkContext.scala
+++ b/core/src/main/scala/org/apache/spark/SparkContext.scala
@@ -1150,11 +1150,6 @@ class SparkContext(config: SparkConf) extends Logging with ExecutorAllocationCli
* Register an RDD to be persisted in memory and/or disk storage
*/
private[spark] def persistRDD(rdd: RDD[_]) {
- _executorAllocationManager.foreach { _ =>
- logWarning(
- s"Dynamic allocation currently does not support cached RDDs. Cached data for RDD " +
- s"${rdd.id} will be lost when executors are removed.")
- }
persistentRdds(rdd.id) = rdd
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org