(rocketmq) branch develop updated: [ISSUE #8532] Fix flush metadata when commit file because of full file (#8533)

[lizhimin]

This is an automated email from the ASF dual-hosted git repository.

lizhimin pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 227be2cf91 [ISSUE #8532] Fix flush metadata when commit file because 
of full file (#8533)
227be2cf91 is described below

commit 227be2cf91f1adb767632159eaffcfb3238adc56
Author: bxfjb <48467309+bx...@users.noreply.github.com>
AuthorDate: Wed Aug 14 23:42:26 2024 +0800

    [ISSUE #8532] Fix flush metadata when commit file because of full file 
(#8533)
---
 .../main/java/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 0c20a1cfb4..891170d703 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 class FlatAppendFile {
                 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;