pavlospt opened a new pull request, #52:
URL: https://github.com/apache/fluss-rust/pull/52
## Description
This PR adds comprehensive integration test coverage for the `list_offsets`
functionality, completing the requirements outlined in issue #47.
## Changes
- ✅ Created new `list_offsets()` integration test with comprehensive
scenarios
- ✅ Tests earliest offset queries on empty table (expects 0)
- ✅ Tests latest offset queries on empty table (expects 0)
- ✅ Appends records and verifies offset tracking:
- Latest offset updates correctly after appending 3 records (expects 3)
- Earliest offset remains stable at 0
- ✅ Tests multi-bucket offset listing
- ✅ Added `OffsetSpec` import for offset type specification
- ✅ Added initialization delay to ensure table is ready before querying
## Test Coverage
The test validates:
1. **Empty table behavior**: Earliest and latest offsets both return 0
2. **Offset tracking**: Latest offset increments correctly after appends
3. **Offset stability**: Earliest offset remains unchanged after appends
4. **Multi-bucket support**: Can query offsets for multiple buckets
## Verification
```bash
cargo test --test test_fluss --features integration_tests list_offsets
```
Test passes successfully in ~25s.
Fixes #47
--
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]
