diff --git a/spark/src/main/scala/geotrellis/spark/ingest/Ingest.scala b/spark/src/main/scala/geotrellis/spark/ingest/Ingest.scala index b5b242d0da..adbe9c601f 100644 --- a/spark/src/main/scala/geotrellis/spark/ingest/Ingest.scala +++ b/spark/src/main/scala/geotrellis/spark/ingest/Ingest.scala @@ -77,7 +77,7 @@ object Ingest { case _ => sourceTiles.collectMetadata(FloatingLayoutScheme(256)) } - val contextRdd = sourceTiles.tileToLayout(tileLayerMetadata, resampleMethod).cache() + val contextRdd = sourceTiles.tileToLayout(tileLayerMetadata, resampleMethod).persist(cacheLevel) val (zoom, tileLayerRdd) = (layoutScheme, maxZoom) match { case (layoutScheme: ZoomedLayoutScheme, Some(mz)) => diff --git a/spark/src/main/scala/geotrellis/spark/ingest/MultibandIngest.scala b/spark/src/main/scala/geotrellis/spark/ingest/MultibandIngest.scala index bd42812ba0..2ad2fac4ad 100644 --- a/spark/src/main/scala/geotrellis/spark/ingest/MultibandIngest.scala +++ b/spark/src/main/scala/geotrellis/spark/ingest/MultibandIngest.scala @@ -51,7 +51,7 @@ object MultibandIngest { case _ => sourceTiles.collectMetadata(FloatingLayoutScheme(256)) } - val contextRdd = sourceTiles.tileToLayout(tileLayerMetadata, resampleMethod).cache() + val contextRdd = sourceTiles.tileToLayout(tileLayerMetadata, resampleMethod).persist(cacheLevel) val (zoom, tileLayerRdd) = (layoutScheme, maxZoom) match { case (layoutScheme: ZoomedLayoutScheme, Some(mz)) =>