Davis-Zhang-Onehouse commented on code in PR #12826:
URL: https://github.com/apache/hudi/pull/12826#discussion_r1976447569
##########
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/RepairCorruptedCleanFilesProcedure.scala:
##########
@@ -63,7 +63,8 @@ class RepairCorruptedCleanFilesProcedure extends
BaseProcedure with ProcedureBui
logWarning("Corruption found. Trying to remove corrupted clean
instant file: " + instant)
TimelineUtils.deleteInstantFile(metaClient.getStorage,
metaClient.getTimelinePath, instant, instantFileNameGenerator)
case ioe: IOException =>
- if (ioe.getMessage.contains("Not an Avro data file")) {
+ if (ioe.getMessage.contains("Not an Avro data file") ||
Review Comment:
because now we throw from serDe class, that class wrap the exception as a
cause of a new exception. so we need to check the cause of the exception now
--
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]
