[INLONG-8060][Sort] Let mysql source reader throws runtimeException w…

…hen connect times out or OOM
EMsnap · May 19, 2023 · 7392c6a · 7392c6a
1 parent 5d38102
commit 7392c6a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...c/src/main/java/org/apache/inlong/sort/cdc/mysql/debezium/reader/SnapshotSplitReader.java b/...c/src/main/java/org/apache/inlong/sort/cdc/mysql/debezium/reader/SnapshotSplitReader.java
@@ -222,6 +222,7 @@ public Iterator<SourceRecord> pollSplitRecords() throws InterruptedException {
             boolean reachBinlogEnd = false;
             final List<SourceRecord> sourceRecords = new ArrayList<>();
             while (!reachBinlogEnd) {
+                checkReadException();
                 List<DataChangeEvent> batch = queue.poll();
                 for (DataChangeEvent event : batch) {
                     sourceRecords.add(event.getRecord());