add param for sqlserver e2e test

apache · Jun 15, 2023 · 8dc2a62 · 8dc2a62
1 parent 621ca21
commit 8dc2a62
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ver-cdc/src/main/java/com/ververica/cdc/connectors/sqlserver/source/offset/LsnOffset.java b/...ver-cdc/src/main/java/com/ververica/cdc/connectors/sqlserver/source/offset/LsnOffset.java
@@ -52,7 +52,7 @@ public LsnOffset(Lsn lsn) {
     }
 
     public Lsn getLcn() {
-        return Lsn.valueOf(offset.get(SourceInfo.COMMIT_LSN_KEY));
+        return Lsn.valueOf(offset.get(SourceInfo.CHANGE_LSN_KEY));
     }
 
     @Override