diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/WriteMarkers.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/WriteMarkers.java index 5cc0f80c2..3dacf1e13 100644 --- a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/WriteMarkers.java +++ b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/WriteMarkers.java @@ -23,7 +23,6 @@ import org.apache.hudi.common.fs.FSUtils; import org.apache.hudi.common.model.IOType; import org.apache.hudi.common.table.HoodieTableMetaClient; import org.apache.hudi.common.util.Option; -import org.apache.hudi.exception.HoodieIOException; import org.apache.hadoop.fs.Path; import org.apache.log4j.LogManager; @@ -87,8 +86,8 @@ public abstract class WriteMarkers implements Serializable { try { context.setJobStatus(this.getClass().getSimpleName(), "Deleting marker directory"); deleteMarkerDir(context, parallelism); - } catch (HoodieIOException ioe) { - LOG.warn("Error deleting marker directory for instant " + instantTime, ioe); + } catch (Exception e) { + LOG.warn("Error deleting marker directory for instant " + instantTime, e); } }