From 54a2b3f28a9443acf31b4ac87b25ac8712cfc3d1 Mon Sep 17 00:00:00 2001 From: mfvitale Date: Fri, 8 Mar 2024 16:29:08 +0100 Subject: [PATCH] DBZ-7305 Fix testNotification --- .../io/debezium/connector/db2/IncrementalSnapshotIT.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/test/java/io/debezium/connector/db2/IncrementalSnapshotIT.java b/src/test/java/io/debezium/connector/db2/IncrementalSnapshotIT.java index 77c9fc4..d12cd58 100644 --- 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