change exception to throwable

streamnative · Oct 31, 2023 · 02a0a39 · 02a0a39
1 parent e0a587a
commit 02a0a39
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/org/apache/pulsar/ecosystem/io/lakehouse/sink/SinkWriter.java b/src/main/java/org/apache/pulsar/ecosystem/io/lakehouse/sink/SinkWriter.java
@@ -113,8 +113,8 @@ public void run() {
                     recordsCnt++;
                     commitIfNeed();
                 }
-            } catch (Exception e) {
-                log.error("process record failed. ", e);
+            } catch (Throwable throwable) {
+                log.error("process record failed. ", throwable);
                 // fail the sink connector.
                 running = false;
             }