luoyuxia opened a new pull request, #3291: URL: https://github.com/apache/fluss/pull/3291
### Purpose Linked issue: close #3290 Fix a tiering log reader bug where `TieringSplitReader` creates a lake writer before it knows whether the current polled batch contains any record below the split `stoppingOffset`. ### Brief change log - Delay lake writer creation in `TieringSplitReader.forLogRecords` until the first record with `record.logOffset() < stoppingOffset` is encountered. - Keep the existing split finishing path unchanged so offset advancement without actual writes no longer produces an empty lake writer commit. - Generative AI disclosure: Codex (GPT-5). ### Tests - Ran `./mvnw -pl fluss-flink/fluss-flink-common -DskipTests spotless:check checkstyle:check`. - Did not run unit or integration tests, per request. ### API and Format No API or storage format changes. ### Documentation No documentation changes. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
