diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java index 18f93faf245f2..40558f2c24229 100644 --- a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java +++ b/hudi-client/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> 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)); } /**