Kaixuan-Duan opened a new pull request, #3306:
URL: https://github.com/apache/fluss/pull/3306
### Purpose
Linked issue: close #3063
### Brief change log
- Modified `RebalanceManager.buildClusterModel()` method to gracefully
handle buckets without LeaderAndIsr information
- Replaced the strict `checkArgument` with a conditional `continue` statement
- Added explanatory comments about the transient state handling
This change addresses the race condition that occurs during table creation
when leader election is not yet completed. The fix allows the rebalance manager
to skip buckets in transient states rather than failing the entire operation.
### Tests
./mvnw -pl fluss-server \\
-Dtest='RebalanceManagerITCase#testBuildClusterModel' \\
-DfailIfNoTests=false \\
test
### API and Format
<!-- Does this change affect API or storage format -->
### Documentation
<!-- Does this change introduce a new feature -->
--
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]
