From 87e19fbcb9dcd33f479ab6438312ce5dae1ba75f Mon Sep 17 00:00:00 2001 From: Koushik Chitta Date: Tue, 17 Sep 2019 13:52:43 -0700 Subject: [PATCH] Flush log before closing. --- core/src/main/scala/kafka/log/LogManager.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/log/LogManager.scala b/core/src/main/scala/kafka/log/LogManager.scala index 8079c988efe1f..4852a3a151de8 100644 --- a/core/src/main/scala/kafka/log/LogManager.scala +++ b/core/src/main/scala/kafka/log/LogManager.scala @@ -860,7 +860,8 @@ class LogManager(logDirs: Seq[File], cleaner.abortCleaning(topicPartition) cleaner.updateCheckpoints(removedLog.dir.getParentFile) } - // Closing the log as we are deleting it + // Flush and Close the log as we are deleting it + removedLog.flush() removedLog.close() removedLog.renameDir(Log.logDeleteDirName(topicPartition)) checkpointRecoveryOffsetsAndCleanSnapshot(removedLog.dir.getParentFile, ArrayBuffer.empty)