diff --git a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/debezium/reader/SnapshotSplitReader.java b/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/debezium/reader/SnapshotSplitReader.java
index d5550ee6acc..f47f28b39ab 100644
--- a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/debezium/reader/SnapshotSplitReader.java
+++ b/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/debezium/reader/SnapshotSplitReader.java
@@ -174,7 +174,7 @@ public void submitSplit(MySqlSplit mySqlSplit) {
                                                     "Read snapshot for mysql split %s fail",
                                                     currentSnapshotSplit)));
                         }
-                    } catch (Exception e) {
+                    } catch (Throwable e) {
                         setReadException(e);
                     }
                 });