diff options
author | Sean Owen <sowen@cloudera.com> | 2015-08-28 09:32:23 +0100 |
---|---|---|
committer | Sean Owen <sowen@cloudera.com> | 2015-08-28 09:32:23 +0100 |
commit | cc39803062119c1d14611dc227b9ed0ed1284d38 (patch) | |
tree | 386a97672b71eba8ddebd999766dfd378b09fef8 | |
parent | 4eeda8d472498acd40ef54723d1be9924a273d76 (diff) | |
download | spark-cc39803062119c1d14611dc227b9ed0ed1284d38.tar.gz spark-cc39803062119c1d14611dc227b9ed0ed1284d38.tar.bz2 spark-cc39803062119c1d14611dc227b9ed0ed1284d38.zip |
[SPARK-10295] [CORE] Dynamic allocation in Mesos does not release when RDDs are cached
Remove obsolete warning about dynamic allocation not working with cached RDDs
See discussion in https://issues.apache.org/jira/browse/SPARK-10295
Author: Sean Owen <sowen@cloudera.com>
Closes #8489 from srowen/SPARK-10295.
-rw-r--r-- | core/src/main/scala/org/apache/spark/SparkContext.scala | 5 |
1 files changed, 0 insertions, 5 deletions
diff --git a/core/src/main/scala/org/apache/spark/SparkContext.scala b/core/src/main/scala/org/apache/spark/SparkContext.scala index f3da04a7f5..738887076b 100644 --- a/core/src/main/scala/org/apache/spark/SparkContext.scala +++ b/core/src/main/scala/org/apache/spark/SparkContext.scala @@ -1590,11 +1590,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 } |