From 094fff41eea3bc8e8f126871be2a53556ce5ff93 Mon Sep 17 00:00:00 2001
From: FocusComputing <xiaoxingstack@gmail.com>
Date: Mon, 14 Aug 2023 11:05:53 +0800
Subject: [PATCH] [hotfix][mysql] Catch underlying throwable in snapshot
 reading.

This closes ##2362.
Co-authored-by: TJX2014 <tangjinxin@deepexi.com>
---
 .../connectors/mysql/debezium/reader/SnapshotSplitReader.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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);
                     }
                 });