Nice! 

> On Oct 7, 2013, at 9:43 PM, Reynold Xin <notifications@github.com> wrote:
> 
> In core/src/main/scala/org/apache/spark/serializer/KryoSerializer.scala:
> 
> > @@ -38,8 +38,6 @@ class KryoSerializer extends org.apache.spark.serializer.Serializer with Logging
> >  
> >    def newKryoOutput() = new KryoOutput(bufferSize)
> >  
> > -  def newKryoInput() = new KryoInput(bufferSize)
> Good catch!
> 
> Any reason why we have newKryoOutput here but not newKryoInput? Maybe we can include that rationale in comment so we don't get confused in the future. Otherwise, LGTM.
> 
> —
> Reply to this email directly or view it on GitHub.