diff LogSegment.scala LogSegment.scala 246a247,249 > /* close the log file and index file before rename */ > close() > diff OffsetIndex.scala OffsetIndex.scala 300,301c300,307 < if(m.isInstanceOf[sun.nio.ch.DirectBuffer]) < (m.asInstanceOf[sun.nio.ch.DirectBuffer]).cleaner().clean() --- > if(m.isInstanceOf[sun.nio.ch.DirectBuffer]) { > var cl = (m.asInstanceOf[sun.nio.ch.DirectBuffer]).cleaner() > > /* if cl != null, then we call it */ > if (cl != null) { > cl.clean() > } > } 334a341,343 > > /* forcefully free the MappedByteBuffer */ > forceUnmap(this.mmap)