From f140c58d9e137a7111b7a53c4bcb8faef50fa8e4 Mon Sep 17 00:00:00 2001 From: Sivabalan Narayanan Date: Tue, 1 Feb 2022 08:21:55 -0500 Subject: [PATCH] [HUDI-3346] Fixing non existant marker dir handling in TwoToOnedowngrade (#4726) --- .../hudi/table/upgrade/TwoToOneDowngradeHandler.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) 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); + } } }