[sqlserver] Fix get latest lsn (apache#2551)

e-mhui · Oct 18, 2023 · a36fe3e · a36fe3e
1 parent 429292e
commit a36fe3e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...cdc/src/main/java/com/ververica/cdc/connectors/sqlserver/source/utils/SqlServerUtils.java b/...cdc/src/main/java/com/ververica/cdc/connectors/sqlserver/source/utils/SqlServerUtils.java
@@ -200,7 +200,7 @@ public static LsnOffset getLsnPosition(Map<String, ?> offset) {
     /** Fetch current largest log sequence number (LSN) of the database. */
     public static LsnOffset currentLsn(SqlServerConnection connection) {
         try {
-            Lsn maxLsn = connection.getMaxLsn(connection.database());
+            Lsn maxLsn = connection.getMaxTransactionLsn(connection.database());
             return new LsnOffset(maxLsn, maxLsn, null);
         } catch (SQLException e) {
             throw new FlinkRuntimeException(e.getMessage(), e);