From 1068bcd7e69c457ef5f86f19ba22b58347f63cd1 Mon Sep 17 00:00:00 2001 From: "yuzhao.cyz" Date: Fri, 27 May 2022 17:38:20 +0800 Subject: [PATCH] [HUDI-4163] Catch general exception instead of IOException while fetching rollback plan during rollback If the avro file is corrupted, an InvalidAvroMagicException throws. --- .../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 251ff97799ffa..5c485bed0581d 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 @@ protected Map> getPendingRollbackInfos 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 {