From a38c4946e3d76645b7575f746084eaae3a1538ec Mon Sep 17 00:00:00 2001 From: zhangjunfan Date: Fri, 24 Apr 2026 15:43:56 +0800 Subject: [PATCH] [server] make RemoteLogManifest sorted with startOffset --- .../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 e1478dec4c..b255b8718d 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 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 RemoteLogManifest trimAndMerge( } } newSegments.addAll(addedSegments); + newSegments.sort(Comparator.comparingLong(RemoteLogSegment::remoteLogStartOffset)); return new RemoteLogManifest(physicalTablePath, tableBucket, newSegments); }