huangjc7 opened a new pull request, #4291: URL: https://github.com/apache/amoro/pull/4291
<img width="3526" height="452" alt="image" src="https://github.com/user-attachments/assets/b735c375-fbe7-4120-9be4-02ee1eb62f6f"; /> Problem: AMS swallowed Iceberg commit exceptions in IcebergInternalTableOperations. As a result, the REST Catalog could return success even when the metadata commit had failed, preventing clients such as Flink from retrying and potentially causing snapshot loss. Fix: Propagate the failure as a CommitFailedException after best-effort metadata cleanup. The REST Catalog now returns HTTP 409, allowing Flink to detect the conflict and retry the commit. The image is from my online production Kubernetes cluster, 409 error. <img width="646" height="426" alt="image" src="https://github.com/user-attachments/assets/171713fb-67ec-47c8-bd93-3461daede738"; /> Data validation is fine. -- 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]
