This looks awesome, @squito!


On Sun, Feb 10, 2013 at 10:11 PM, Stephen Haberman <notifications@github.com
> wrote:

> In core/src/main/scala/spark/rdd/CheckpointRDD.scala:
>
> > @@ -104,7 +104,7 @@ private[spark] object CheckpointRDD extends Logging {
> >      val deserializeStream = serializer.deserializeStream(fileInputStream)
> >
> >      // Register an on-task-completion callback to close the input stream.
> > -    context.addOnCompleteCallback(() => deserializeStream.close())
> > +    context.addOnCompleteCallback(_ => deserializeStream.close())
>
> Oh, sorry, I see you changed on addOnCompleteCallback works.
>
> —
> Reply to this email directly or view it on GitHub<https://github.com/mesos/spark/pull/462/files#r2957587>..
>
>