From a36fe3e46992a2e6b1db124599b43b650d257f77 Mon Sep 17 00:00:00 2001
From: gongzhongqiang <gongzhongqiang@apache.org>
Date: Mon, 16 Oct 2023 13:15:29 +0800
Subject: [PATCH] [sqlserver] Fix get latest lsn (#2551)

---
 .../cdc/connectors/sqlserver/source/utils/SqlServerUtils.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-connector-sqlserver-cdc/src/main/java/com/ververica/cdc/connectors/sqlserver/source/utils/SqlServerUtils.java b/flink-connector-sqlserver-cdc/src/main/java/com/ververica/cdc/connectors/sqlserver/source/utils/SqlServerUtils.java
index 9f03bde2fdd..9743384c657 100644
--- a/flink-connector-sqlserver-cdc/src/main/java/com/ververica/cdc/connectors/sqlserver/source/utils/SqlServerUtils.java
+++ b/flink-connector-sqlserver-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);