[flink] Enable undo-based recovery after Flink job failover to ensure exactly-once semantics and data consistency.
Open
- Dominant language
- Java
- Stars
- 2.1k
- Forks
- 625
- Avg merge
- 3d 14h
- Merged PRs (30d)
- 97
Description
### Search before asking
- [x] I searched in the [issues](https://github.com/apache/fluss/issues) and found nothing similar.
### Description
Enable undo-based recovery after Flink job failover to ensure exactly-once semantics and data consistency.
### Willingness to contribute
- [ ] I'm willing to submit a PR!
Contributor guide
No contributing guide indexed for this repository
Research direction
No files, tests, or entry points are identified. Start by locating the Flink failover and recovery paths, then determine the scope of undo-based recovery and how exactly-once semantics and data consistency are verified; done should include recovery after job failover with those guarantees demonstrated by tests.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java
- Domain
- distributed-systems
- Issue type
- Feature
- Difficulty
- 5/5
- Estimated time
- Over a week
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 25/100