lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[Minor] Catch and ignore all the exceptions in quietDeleteMarkerDir (#4301)

Browse Source 
Co-authored-by: yuezhang <yuezhang@freewheel.tv>
This commit is contained in:
zhangyue19921010
2021-12-17 03:15:08 +08:00
committed by GitHub
parent ea2eba1a55
commit a8a192aef5
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/WriteMarkers.java
View File

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