diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/TwoToOneDowngradeHandler.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/TwoToOneDowngradeHandler.java index 0a2e0f813..de1a1067f 100644 --- a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/TwoToOneDowngradeHandler.java +++ b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/TwoToOneDowngradeHandler.java @@ -115,9 +115,11 @@ public class TwoToOneDowngradeHandler implements DowngradeHandler { + "\" is not supported for rollback."); } } else { - // In case of partial failures during downgrade, there is a chance that marker type file was deleted, - // but timeline server based marker files are left. So deletes them if any - deleteTimelineBasedMarkerFiles(context, markerDir, fileSystem, parallelism); + if (fileSystem.exists(new Path(markerDir))) { + // In case of partial failures during downgrade, there is a chance that marker type file was deleted, + // but timeline server based marker files are left. So deletes them if any + deleteTimelineBasedMarkerFiles(context, markerDir, fileSystem, parallelism); + } } }