From 227be2cf91f1adb767632159eaffcfb3238adc56 Mon Sep 17 00:00:00 2001 From: bxfjb <48467309+bxfjb@users.noreply.github.com> Date: Wed, 14 Aug 2024 23:42:26 +0800 Subject: [PATCH] [ISSUE #8532] Fix flush metadata when commit file because of full file (#8533) --- .../org/apache/rocketmq/tieredstore/file/FlatAppendFile.java | 1 + 1 file changed, 1 insertion(+) diff --git a/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatAppendFile.java b/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatAppendFile.java index 0c20a1cfb4f..891170d703a 100644 --- a/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatAppendFile.java +++ b/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatAppendFile.java @@ -180,6 +180,7 @@ public AppendResult append(ByteBuffer buffer, long timestamp) { log.info("FlatAppendFile#append not successful for the file {} is full, commit result={}", fileSegment.getPath(), commitResult); if (commitResult) { + this.flushFileSegmentMeta(fileSegment); return this.rollingNewFile(this.getAppendOffset()).append(buffer, timestamp); } else { return AppendResult.UNKNOWN_ERROR;