diff --git a/pom.xml b/pom.xml
index 1ed035f..f2ea68d 100644
--- a/pom.xml
+++ b/pom.xml
@@ -62,6 +62,7 @@
     <aws.sdk.version>1.12.220</aws.sdk.version>
     <gcs.version>hadoop3-2.2.1</gcs.version>
     <curator.version>2.12.0</curator.version>
+    <snappy.java.version>1.1.8.4</snappy.java.version>
 
     <!-- test dependencies -->
     <testng.version>7.3.0</testng.version>
@@ -250,6 +251,12 @@
         <version>${slf4j.version}</version>
       </dependency>
 
+      <dependency>
+        <groupId>org.xerial.snappy</groupId>
+        <artifactId>snappy-java</artifactId>
+        <version>${snappy.java.version}</version>
+      </dependency>
+
       <!--  Hoodie dependencies begin   -->
       <dependency>
         <groupId>org.apache.hudi</groupId>
@@ -429,6 +436,11 @@
       <artifactId>slf4j-simple</artifactId>
     </dependency>
 
+    <dependency>
+      <groupId>org.xerial.snappy</groupId>
+      <artifactId>snappy-java</artifactId>
+    </dependency>
+
     <dependency>
       <groupId>org.apache.logging.log4j</groupId>
       <artifactId>log4j-slf4j-impl</artifactId>
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
index 2b1bc39..1751d69 100644
--- 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;
             }