diff --git a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/debezium/reader/SnapshotSplitReader.java b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/debezium/reader/SnapshotSplitReader.java index 1d62a929cb3..87effb4d77c 100644 --- a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/debezium/reader/SnapshotSplitReader.java +++ b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/debezium/reader/SnapshotSplitReader.java @@ -222,6 +222,7 @@ public Iterator pollSplitRecords() throws InterruptedException { boolean reachBinlogEnd = false; final List sourceRecords = new ArrayList<>(); while (!reachBinlogEnd) { + checkReadException(); List batch = queue.poll(); for (DataChangeEvent event : batch) { sourceRecords.add(event.getRecord());