fhan688 opened a new pull request, #3522:
URL: https://github.com/apache/fluss/pull/3522
### Purpose
Linked issue: N/A
This PR adds the shared Flink union read test base for Hudi, preparing
follow-up IT cases for validating Hudi tiering union reads from lake snapshots
and Fluss logs.
### Brief change log
- Add `FlinkUnionReadTestBase` for Hudi union read tests.
- Initialize batch and streaming `StreamTableEnvironment` with the Fluss
catalog.
- Support rebuilding the streaming table environment from a savepoint path.
- Add reusable Hudi tiering test helpers for waiting bucket sync and
asserting replica lake offsets.
### Tests
- `spotless:apply`
- `mvn -pl fluss-lake/fluss-lake-hudi -am -DskipITs -Dcheckstyle.skip=true
-DfailIfNoTests=false test-compile`
- `git diff --check`
### API and Format
No public API or storage format changes. This is test-only infrastructure.
### Documentation
No documentation changes are needed.
--
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]
