Skip to content

Commit 931e492

Browse files
GOODBOY008zhangchaoming.zcm
authored andcommitted
[sqlserver] Fix get latest lsn (apache#2551)
1 parent 8aa3789 commit 931e492

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)