[CELEBORN-1601] Support revise lost shuffles
What changes were proposed in this pull request?
To support revising lost shuffle IDs in a long-running job such as flink batch jobs.
Why are the changes needed?
- To support revise lost shuffles.
- To add an HTTP endpoint to revise lost shuffles manually.
Does this PR introduce any user-facing change?
NO.
How was this patch tested?
Cluster tests.
@FMX, could you also support the corresponding cli command for the HTTP endpoint to revise lost shuffles?
@FMX, could you also support the corresponding cli command for the HTTP endpoint to revise lost shuffles?
Sounds good. I'll add the cli command.
@FMX, BTW, the HTTP endpoint should introduce the client api to invoke, which could follow README.md to add.
@SteNicholas Thanks. I have added the CLI command and the API endpoint. Please review this PR when you have time.
This PR is stale because it has been open 20 days with no activity. Remove stale label or comment or this will be closed in 10 days.
Thanks. Merged to main(v0.6.0).