We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d208047 commit 6fd74d8Copy full SHA for 6fd74d8
core/src/main/scala/org/apache/spark/SparkContext.scala
@@ -1150,11 +1150,6 @@ class SparkContext(config: SparkConf) extends Logging with ExecutorAllocationCli
1150
* Register an RDD to be persisted in memory and/or disk storage
1151
*/
1152
private[spark] def persistRDD(rdd: RDD[_]) {
1153
- _executorAllocationManager.foreach { _ =>
1154
- logWarning(
1155
- s"Dynamic allocation currently does not support cached RDDs. Cached data for RDD " +
1156
- s"${rdd.id} will be lost when executors are removed.")
1157
- }
1158
persistentRdds(rdd.id) = rdd
1159
}
1160
0 commit comments