Skip to content

Commit 6f9a064

Browse files
authored
[sqlserver] Fix get latest lsn (#2551)
1 parent 7e9cbfd commit 6f9a064

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

flink-connector-sqlserver-cdc/src/main/java/com/ververica/cdc/connectors/sqlserver/source/utils/SqlServerUtils.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -200,7 +200,7 @@ public static LsnOffset getLsnPosition(Map<String, ?> offset) {
200200
/** Fetch current largest log sequence number (LSN) of the database. */
201201
public static LsnOffset currentLsn(SqlServerConnection connection) {
202202
try {
203-
Lsn maxLsn = connection.getMaxLsn(connection.database());
203+
Lsn maxLsn = connection.getMaxTransactionLsn(connection.database());
204204
return new LsnOffset(maxLsn, maxLsn, null);
205205
} catch (SQLException e) {
206206
throw new FlinkRuntimeException(e.getMessage(), e);

0 commit comments

Comments
 (0)