KAFKA-1757 Unmap file prior to delete on windows.

LioRoger · Feb 22, 2015 · 3f1e088 · 3f1e088
1 parent 62c7e0e
commit 3f1e088
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/core/src/main/scala/kafka/log/OffsetIndex.scala b/core/src/main/scala/kafka/log/OffsetIndex.scala
@@ -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()
   }