[log] Fix TabletServer cannot recover because OutOfOrderSequenceException by wrongly done takeSnapshot (apache#732)

swuferhong · web-flow · commit 4e7b552f63d9 · 2025-04-11T12:11:03.000+08:00
diff --git a/fluss-server/src/main/java/com/alibaba/fluss/server/log/LogTablet.java b/fluss-server/src/main/java/com/alibaba/fluss/server/log/LogTablet.java
@@ -1160,7 +1160,7 @@ static void rebuildWriterState(
                                     logStartOffset);
                     writerStateManager.updateMapEndOffset(startOffset);
 
-                    if (offsetsToSnapshot.contains(Optional.of(startOffset))) {
+                    if (offsetsToSnapshot.contains(Optional.of(segment.getBaseOffset()))) {
                         writerStateManager.takeSnapshot();
                     }
 

Original file line number	Diff line number	Diff line change
`@@ -1160,7 +1160,7 @@ static void rebuildWriterState(`
`1160`	`1160`	`logStartOffset);`
`1161`	`1161`	`writerStateManager.updateMapEndOffset(startOffset);`
`1162`	`1162`
`1163`		`- if (offsetsToSnapshot.contains(Optional.of(startOffset))) {`
	`1163`	`+ if (offsetsToSnapshot.contains(Optional.of(segment.getBaseOffset()))) {`
`1164`	`1164`	`writerStateManager.takeSnapshot();`
`1165`	`1165`	`}`
`1166`	`1166`