YuweiXiao opened a new pull request, #6737: URL: https://github.com/apache/hudi/pull/6737
### Change Logs Implement consistent hashing bucket index for flink. This PR only covers the write core of the index, and the resizing implementation will be in another PR. There are three main changes: - Extract common code of consistent hashing bucket index, to serve both Spark&Flink engine. - Have Flink engine write path adapt to consistent hashing bucket index, e.g., introduce `ConsistentBucketStreamWriteOperator ` - Introduce the basic framework of `UpdateStrategy` for Flink, to handle conflict between concurrent clustering & update. ### Impact No public API change. **Risk level: none | low | medium | high** Low ### Contributor's checklist - [x] Read through [contributor's guide](https://hudi.apache.org/contribute/how-to-contribute) - [x] Change Logs and Impact were stated clearly - [ ] Adequate tests were added if applicable - [ ] CI passed -- 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: commits-unsubscr...@hudi.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
