DBZ-7305 Fix testNotification

rohan-flutterint · Mar 14, 2024 · 54a2b3f · 54a2b3f
1 parent 59d6c09
commit 54a2b3f
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/test/java/io/debezium/connector/db2/IncrementalSnapshotIT.java b/src/test/java/io/debezium/connector/db2/IncrementalSnapshotIT.java
@@ -157,6 +157,7 @@ protected String returnedIdentifierName(String queriedID) {
         return queriedID.toUpperCase();
     }
 
+    @Override
     protected void sendAdHocSnapshotSignal() throws SQLException {
         connection.execute(
                 String.format(
@@ -168,7 +169,7 @@ protected void sendAdHocSnapshotSignal() throws SQLException {
     @Override
     protected Builder config() {
         return TestHelper.defaultConfig()
-                .with(Db2ConnectorConfig.SNAPSHOT_MODE, SnapshotMode.SCHEMA_ONLY)
+                .with(Db2ConnectorConfig.SNAPSHOT_MODE, SnapshotMode.NO_DATA)
                 .with(Db2ConnectorConfig.SIGNAL_DATA_COLLECTION, "DB2INST1.DEBEZIUM_SIGNAL")
                 .with(Db2ConnectorConfig.INCREMENTAL_SNAPSHOT_CHUNK_SIZE, 250)
                 .with(RelationalDatabaseConnectorConfig.MSG_KEY_COLUMNS, "DB2INST1.A42:pk1,pk2,pk3,pk4");
@@ -203,7 +204,7 @@ protected String valueFieldName() {
 
     @Override
     protected int defaultIncrementalSnapshotChunkSize() {
-        return 250;
+        return 100;
     }
 
     @Override