cshuo opened a new pull request, #18789:
URL: https://github.com/apache/hudi/pull/18789
… both global and partitioned RLI
### Describe the issue this Pull Request addresses
Flink streaming recovery can leave pending instants that need to be
recommitted before record level index state is bootstrapped or reused after
failover. The previous guard was tied specifically to global RLI bootstrap
configuration, which made the recovery/failover handling too narrow for
RLI-backed writes.
This PR adjusts the write coordinator recovery path so pending instant
recommits and follow-up failover handling are driven from the coordinator's
table-state RLI flag rather than the removed bootstrap-specific helper.
### Summary and Changelog
- Removed `OptionsResolver.isRLIWithBootstrap`, which only checked global
RLI with index bootstrap enabled.
- Updated `StreamWriteOperatorCoordinator` reset and subtask-reset paths to
use `tableState.isRecordLevelIndex` when recommitting pending instants.
- Updated bootstrap event handling to trigger job failover after pending
instants are recommitted for RLI tables, allowing the RLI bootstrap operator to
reload index state completely.
- Added `TableState.isRecordLevelIndex` to centralize the coordinator's
RLI-related recovery decision.
### Impact
RLI recovery handling is intended to apply to both global and partitioned
RLI paths when pending instants are recommitted after restart or failover.
### Risk Level
<!-- Accepted values: none, low, medium or high. Other than `none`, explain
the risk.
If medium or high, explain what verification was done to mitigate the
risks. -->
### Documentation Update
<!-- Describe any necessary documentation update if there is any new
feature, config, or user-facing change. If not, put "none".
- The config description must be updated if new configs are added or the
default value of the configs are changed.
- Any new feature or user-facing change requires updating the Hudi website.
Please follow the
[instruction](https://hudi.apache.org/contribute/developer-setup#website)
to make changes to the website. -->
### Contributor's checklist
- [ ] Read through [contributor's
guide](https://hudi.apache.org/contribute/how-to-contribute)
- [ ] Enough context is provided in the sections above
- [ ] Adequate tests were added if applicable
--
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]
