(fluss) branch main updated: [server] make RemoteLogManifest sorted with startOffset (#3194)

[aborisov]

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

fresh-borzoni pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new 7dd9e8e37 [server] make RemoteLogManifest sorted with startOffset 
(#3194)
7dd9e8e37 is described below

commit 7dd9e8e37c2ee49ffea58073c461cab34f46deee
Author: Junfan Zhang <zus...@apache.org>
AuthorDate: Thu May 28 23:58:19 2026 +0800

    [server] make RemoteLogManifest sorted with startOffset (#3194)
    
    Co-authored-by: zhangjunfan <zhangjun...@qiyi.com>
---
 .../main/java/org/apache/fluss/server/log/remote/RemoteLogManifest.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/fluss-server/src/main/java/org/apache/fluss/server/log/remote/RemoteLogManifest.java
 
b/fluss-server/src/main/java/org/apache/fluss/server/log/remote/RemoteLogManifest.java
index e1478dec4..b255b8718 100644
--- 
a/fluss-server/src/main/java/org/apache/fluss/server/log/remote/RemoteLogManifest.java
+++ 
b/fluss-server/src/main/java/org/apache/fluss/server/log/remote/RemoteLogManifest.java
@@ -24,6 +24,7 @@ import org.apache.fluss.remote.RemoteLogSegment;
 
 import java.util.ArrayList;
 import java.util.Collections;
+import java.util.Comparator;
 import java.util.List;
 import java.util.Objects;
 import java.util.Set;
@@ -73,6 +74,7 @@ public class RemoteLogManifest {
             }
         }
         newSegments.addAll(addedSegments);
+        
newSegments.sort(Comparator.comparingLong(RemoteLogSegment::remoteLogStartOffset));
         return new RemoteLogManifest(physicalTablePath, tableBucket, 
newSegments);
     }