Jiayi-Liao opened a new pull request #11480: [FLINK-16597] handle exception thrown from close method in OutputFormat URL: https://github.com/apache/flink/pull/11480 ## What is the purpose of the change The `format.close()` in finally block in #DataSinkTask#invoke is not properly handled but only logged. ## Brief change log 1. Remove the `format.close()` in finally block and add a new try-catch-finally block inside the original try-catch block. ## Verifying this change Unit tests to verify the `tryCleanupOnError` is executed when exception is thrown from `format.close()`. ## Does this pull request potentially affect one of the following parts: ## Documentation
---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
