You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by da...@apache.org on 2022/05/30 05:08:08 UTC
[hudi] branch master updated: [HUDI-4163] Catch general exception instead of IOException while fetching rollback plan during rollback (#5703)
This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new 329da34ee0 [HUDI-4163] Catch general exception instead of IOException while fetching rollback plan during rollback (#5703)
329da34ee0 is described below
commit 329da34ee0f8d935fa7ec1853104addfb5b45400
Author: Danny Chan <yu...@gmail.com>
AuthorDate: Mon May 30 13:08:02 2022 +0800
[HUDI-4163] Catch general exception instead of IOException while fetching rollback plan during rollback (#5703)
If the avro file is corrupted, an InvalidAvroMagicException throws.
---
.../src/main/java/org/apache/hudi/client/BaseHoodieWriteClient.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieWriteClient.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieWriteClient.java
index 251ff97799..5c485bed05 100644
--- a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieWriteClient.java
+++ b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieWriteClient.java
@@ -1118,7 +1118,7 @@ public abstract class BaseHoodieWriteClient<T extends HoodieRecordPayload, I, K,
HoodieRollbackPlan rollbackPlan;
try {
rollbackPlan = RollbackUtils.getRollbackPlan(metaClient, rollbackInstant);
- } catch (IOException e) {
+ } catch (Exception e) {
if (rollbackInstant.isRequested()) {
LOG.warn("Fetching rollback plan failed for " + rollbackInstant + ", deleting the plan since it's in REQUESTED state", e);
try {