(seatunnel) branch dev updated: [Fix][Connector-V2][SqlServer CDC] Fix SQL Server CDC DDL history query LSN boundary causing schema events to be lost (#10970)

[zengyi]

This is an automated email from the ASF dual-hosted git repository.

yzeng1618 pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new f9a6ef97a0 [Fix][Connector-V2][SqlServer CDC] Fix SQL Server CDC DDL 
history query LSN boundary causing schema events to be lost (#10970)
f9a6ef97a0 is described below

commit f9a6ef97a0c9493f61c9ba7af446a6242069623d
Author: cloverdew <clover...@gmail.com>
AuthorDate: Fri May 29 17:25:04 2026 +0800

    [Fix][Connector-V2][SqlServer CDC] Fix SQL Server CDC DDL history query LSN 
boundary causing schema events to be lost (#10970)
---
 .../main/java/io/debezium/connector/sqlserver/SqlServerConnection.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerConnection.java
 
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerConnection.java
index 0c790b954a..62e9555b45 100644
--- 
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerConnection.java
+++ 
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerConnection.java
@@ -136,7 +136,7 @@ public class SqlServerConnection extends JdbcConnection {
                     + " ddl_lsn,"
                     + " ddl_time"
                     + " FROM [#db].cdc.ddl_history"
-                    + " WHERE ddl_lsn > ? AND ddl_lsn <= ?"
+                    + " WHERE ddl_lsn >= ? AND ddl_lsn <= ?"
                     + " ORDER BY ddl_lsn ASC";
     private static final String OPENING_QUOTING_CHARACTER = "[";
     private static final String CLOSING_QUOTING_CHARACTER = "]";