fix rebase issue

apache · Jun 9, 2023 · 4c3ef9d · 4c3ef9d
1 parent 29e0c26
commit 4c3ef9d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/flink-cdc-e2e-tests/src/test/java/com/ververica/cdc/connectors/tests/PostgresE2eITCase.java b/flink-cdc-e2e-tests/src/test/java/com/ververica/cdc/connectors/tests/PostgresE2eITCase.java
@@ -136,6 +136,7 @@ public void after() {
                     " 'database-name' = '" + POSTGRES.getDatabaseName() + "',",
                     " 'schema-name' = 'inventory',",
                     " 'table-name' = 'products',",
+                    " 'slot.name' = 'flink_incremental',",
                     " 'scan.incremental.snapshot.chunk.size' = '5',",
                     " 'scan.incremental.snapshot.enabled' = 'true',",
                     " 'scan.startup.mode' = 'initial'",

diff --git a/...main/java/com/ververica/cdc/connectors/sqlserver/source/config/SqlServerSourceConfig.java b/...main/java/com/ververica/cdc/connectors/sqlserver/source/config/SqlServerSourceConfig.java
@@ -57,6 +57,7 @@ public SqlServerSourceConfig(
         super(
                 startupOptions,
                 databaseList,
+                null,
                 tableList,
                 splitSize,
                 splitMetaGroupSize,