[sqlserver] Fix get latest lsn (#2551)

(cherry picked from commit 6f9a064)
apache · Oct 31, 2023 · 80cd840 · 80cd840
1 parent 5e8b773
commit 80cd840
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);