fhan688 opened a new pull request, #3503:
URL: https://github.com/apache/fluss/pull/3503
### Purpose
Linked issue: https://github.com/apache/fluss/issues/3279
This PR introduces split tags for the tiering source so lake writers can
coordinate all splits that belong to the same tiering round. Each generated
tiering round has one first-split tag and a shared round tag for the remaining
splits.
### Brief change log
- Add `WriterInitContext#tag()` as a default method.
- Add immutable tag support to `TieringSplit`, `TieringLogSplit`, and
`TieringSnapshotSplit`.
- Populate tiering-round tags when generating splits.
- Preserve split tags through copy, split state conversion, and split
serialization.
- Pass split tags from `TieringSplitReader` to `TieringWriterInitContext`.
- Add tests for tag serialization, state conversion, and tag assignment.
### Tests
- `git diff --check`
- `mvn -pl fluss-flink/fluss-flink-common -am -DskipITs
-Dcheckstyle.skip=true -DfailIfNoTests=false
-Dtest=TieringSplitSerializerTest,TieringSplitStateTest test`
### API and Format
- Adds a source-compatible default method `WriterInitContext#tag()`.
- Updates internal `TieringSplitSerializer` version to include split tags.
- Does not change Fluss table data format or lake storage format.
### Documentation
No user-facing 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]
