Skip to content

Commit

Permalink
DBZ-7305 Fix testNotification
Browse files Browse the repository at this point in the history
  • Loading branch information
mfvitale committed Mar 8, 2024
1 parent d5a3e72 commit 784900c
Showing 1 changed file with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -157,6 +157,7 @@ protected String returnedIdentifierName(String queriedID) {
return queriedID.toUpperCase();
}

@Override
protected void sendAdHocSnapshotSignal() throws SQLException {
connection.execute(
String.format(
Expand All @@ -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");
Expand Down Expand Up @@ -203,7 +204,7 @@ protected String valueFieldName() {

@Override
protected int defaultIncrementalSnapshotChunkSize() {
return 250;
return 100;
}

@Override
Expand Down

0 comments on commit 784900c

Please sign in to comment.