From 5a7d1b3d6cb42b1763654e307625e2ae7b799adc Mon Sep 17 00:00:00 2001
From: swuferhong <337361684@qq.com>
Date: Tue, 29 Jun 2021 22:43:47 +0800
Subject: [PATCH] [HUDI-2097] Fix Flink unable to read commit metadata error
 (#3180)

---
 .../apache/hudi/sink/partitioner/profile/WriteProfiles.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/profile/WriteProfiles.java b/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/profile/WriteProfiles.java
index d62b2086a..093cef5be 100644
--- a/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/profile/WriteProfiles.java
+++ b/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/profile/WriteProfiles.java
@@ -157,10 +157,10 @@ public class WriteProfiles {
       // make this fail safe.
       LOG.warn("Instant {} was deleted by the cleaner, ignore", instant.getTimestamp());
       return Option.empty();
-    } catch (IOException e) {
+    } catch (Throwable throwable) {
       LOG.error("Get write metadata for table {} with instant {} and path: {} error",
           tableName, instant.getTimestamp(), basePath);
-      throw new HoodieException(e);
+      return Option.empty();
     }
   }