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;