skip query when size is 1

apache · Aug 12, 2024 · 145b7a7 · 145b7a7
1 parent 0144508
commit 145b7a7
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/DebeziumUtils.java b/...mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/DebeziumUtils.java
@@ -247,6 +247,9 @@ public static BinlogOffset findBinlogOffset(
         if (binlogFiles.isEmpty()) {
             return BinlogOffset.ofBinlogFilePosition("", 0);
         }
+        if (binlogFiles.size() == 1) {
+            return BinlogOffset.ofBinlogFilePosition(binlogFiles.get(0), 0);
+        }
 
         BinaryLogClient client = createBinaryClient(mySqlSourceConfig.getDbzConfiguration());
         if (mySqlSourceConfig.getServerIdRange() != null) {