danny0405 commented on issue #18051: URL: https://github.com/apache/hudi/issues/18051#issuecomment-3821945376
I think it is another case, that is when during instant commit, if errors are found in the write status, Flink will not commit the instant and rolls it back instead, that would cause the data loss and needs a fix, the solution might be just throwing in the write function when errors are dected just like what we do to the append function: https://github.com/apache/hudi/pull/13417, instead of logging, we should throw. -- 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]
