[HUDI-2997] Skip the corrupt meta file for pending rollback action

apache · Dec 13, 2021 · 6aa8c34 · 6aa8c34
1 parent b22c2c6
commit 6aa8c34
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...nt/hudi-client-common/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java b/...nt/hudi-client-common/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java
@@ -85,6 +85,7 @@
 import java.util.LinkedHashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.Objects;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
@@ -909,10 +910,11 @@ protected Map<String, Option<HoodiePendingRollbackInfo>> getPendingRollbackInfos
             HoodieRollbackPlan rollbackPlan = RollbackUtils.getRollbackPlan(metaClient, entry);
             return Pair.of(rollbackPlan.getInstantToRollback().getCommitTime(), Option.of(new HoodiePendingRollbackInfo(entry, rollbackPlan)));
           } catch (IOException e) {
-            throw new HoodieIOException("Fetching rollback plan failed for " + entry, e);
+            LOG.warn("Fetching rollback plan failed for " + entry + ", skip the plan", e);
+            return null;
           }
         }
-    ).collect(Collectors.toMap(Pair::getKey, Pair::getValue));
+    ).filter(Objects::nonNull).collect(Collectors.toMap(Pair::getKey, Pair::getValue));
   }
 
   /**