SteNicholas opened a new pull request, #9211: URL: https://github.com/apache/hudi/pull/9211
### Change Logs The failed writes clean policy should be lazy when write concurrency mode is optimistic concurrency control. `FlinkOptions` should support to config failed writes clean policy. The parameters of `FlinkStreamerConfig`, `FlinkCompactionConfig` and `FlinkClusteringConfig` should also support failed writes clean policy parameter. Meanwhile, append mode without inline clustering should add clean operator in pipeline to rollback failed writes. ### Impact `FlinkOptions`, `FlinkStreamerConfig`, `FlinkCompactionConfig` and `FlinkClusteringConfig` supports to config failed writes clean policy. Meanwhile, append mode without inline clustering adds clean operator in pipeline to rollback failed writes via lazy failed writes clean policy. ### Risk level (write none, low medium or high below) none. ### Documentation Update none. ### 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 - [x] Adequate tests were added if applicable - [x] 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
