From 34d2206a75109a4c0232d2668342393840a2a552 Mon Sep 17 00:00:00 2001 From: Chris Black Date: Mon, 22 Jun 2015 00:35:49 -0700 Subject: [PATCH] KAFKA-2290; OffsetIndex should open RandomAccessFile consistently --- core/src/main/scala/kafka/log/OffsetIndex.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/log/OffsetIndex.scala b/core/src/main/scala/kafka/log/OffsetIndex.scala index a1082ae..332d5e2 100755 --- a/core/src/main/scala/kafka/log/OffsetIndex.scala +++ b/core/src/main/scala/kafka/log/OffsetIndex.scala @@ -274,7 +274,7 @@ class OffsetIndex(@volatile var file: File, val baseOffset: Long, val maxIndexSi */ def resize(newSize: Int) { inLock(lock) { - val raf = new RandomAccessFile(file, "rws") + val raf = new RandomAccessFile(file, "rw") val roundedNewSize = roundToExactMultiple(newSize, 8) val position = this.mmap.position -- 2.1.3.36.g8e36a6d