Which is private to spark iirc ?
But agreed about incorrect assumption.
Doing it cleanly is much more involved than just going to master for
various replication levels and caching that per level ... We would need a
block placement spi like what NN exposes
On 27-May-2014 10:51 am, "Aaron Davidson" <notifications@github.com> wrote:

> In core/src/main/scala/org/apache/spark/storage/BlockManager.scala:
>
> > @@ -772,7 +772,7 @@ private[spark] class BlockManager(
> >    /**
> >     * Replicate block to another node.
> >     */
> > -  var cachedPeers: Seq[BlockManagerId] = null
> > +  @volatile var cachedPeers: Seq[BlockManagerId] = null
>
> Spark should not be making assumptions about the replication level like
> that. StorageLevel has a fully public apply() to construct new ones.
>
> —
> Reply to this email directly or view it on GitHub<https://github.com/apache/spark/pull/887/files#r13062499>
> .
>