[ISSUE #8532] Fix flush metadata when commit file because of full file (

#8533)
apache · Aug 14, 2024 · 227be2c · 227be2c
1 parent 524ca4e
commit 227be2c
Showing 1 changed file with 1 addition and 0 deletions.
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
@@ -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;