diff --git a/src/test/java/io/debezium/connector/db2/IncrementalSnapshotIT.java b/src/test/java/io/debezium/connector/db2/IncrementalSnapshotIT.java index 77c9fc4..b4acf6d 100644 --- a/src/test/java/io/debezium/connector/db2/IncrementalSnapshotIT.java +++ b/src/test/java/io/debezium/connector/db2/IncrementalSnapshotIT.java @@ -157,6 +157,8 @@ protected String returnedIdentifierName(String queriedID) { return queriedID.toUpperCase(); } + + @Override protected void sendAdHocSnapshotSignal() throws SQLException { connection.execute( String.format( @@ -168,7 +170,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 +205,7 @@ protected String valueFieldName() { @Override protected int defaultIncrementalSnapshotChunkSize() { - return 250; + return 100; } @Override