nevzheng opened a new pull request, #12263: URL: https://github.com/apache/gravitino/pull/12263
### What changes were proposed in this pull request? This is Stack 30, PR 7 of 8. - Add `async-cleanup.max-inflight-jobs` with default `100`. - Add `async-cleanup.enqueue-batch-size` with default `20`. - Bound candidate scanning by the observed available queue capacity. - Resolve immutable parents, capture cleanup context while the route is reserved, and invoke the existing atomic handoff. - Leave candidates whose context cannot be captured safely in `DELETED` for a later pass. - Use an advisory in-memory keyset cursor to move past an unpreparable head window. After this PR, an explicitly invoked coordinator can turn eligible deletion actions into bounded durable jobs without performing cleanup itself. ### Why are the changes needed? The durable worker path needs a bounded bridge from retention expiry to atomic job enqueue. Part of #12258. ### Does this PR introduce _any_ user-facing change? It adds two internal configuration properties. It introduces no HTTP endpoint. ### How was this patch tested? Test coverage is included for capacity and batch bounds, cursor advancement, exact parent routing, context failure, temporary credentials, concurrent claims, and inflight queries. No post-rebase local test run was performed; CI validation is pending. -- 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]
