Browse Source

KAFKA-1757 Unmap file prior to delete on windows.

pull/1442/head
Jay Kreps 10 years ago
parent
commit
3f1e088229
  1. 2
      core/src/main/scala/kafka/log/OffsetIndex.scala

2
core/src/main/scala/kafka/log/OffsetIndex.scala

@ -318,6 +318,8 @@ class OffsetIndex(@volatile var file: File, val baseOffset: Long, val maxIndexSi @@ -318,6 +318,8 @@ class OffsetIndex(@volatile var file: File, val baseOffset: Long, val maxIndexSi
*/
def delete(): Boolean = {
info("Deleting index " + this.file.getAbsolutePath)
if(Os.isWindows)
Utils.swallow(forceUnmap(this.mmap))
this.file.delete()
}

Loading…
Cancel
Save