Skip to content

Commit 4c58701

Browse files
mukesh-ctdssrinath-ctds
authored andcommitted
Reverted changes for oracle
1 parent 4788375 commit 4c58701

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumOracleDbSourceTester.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ public DebeziumOracleDbSourceTester(PulsarCluster cluster) {
5050
super(NAME);
5151
this.pulsarCluster = cluster;
5252
this.numEntriesToInsert = 1;
53-
this.numEntriesExpectAfterStart = 1;
53+
this.numEntriesExpectAfterStart = 0;
5454

5555
pulsarServiceUrl = "pulsar://pulsar-proxy:" + PulsarContainer.BROKER_PORT;
5656

@@ -61,7 +61,7 @@ public DebeziumOracleDbSourceTester(PulsarCluster cluster) {
6161
sourceConfig.put("database.password", "dbz");
6262
sourceConfig.put("database.server.name", "XE");
6363
sourceConfig.put("database.dbname", "XE");
64-
sourceConfig.put("database.whitelist", "inv");
64+
sourceConfig.put("snapshot.mode", "schema_only");
6565
sourceConfig.put("schema.include.list", "inv");
6666
sourceConfig.put("schema.history.internal.pulsar.service.url", pulsarServiceUrl);
6767
sourceConfig.put("topic.namespace", "debezium/oracle");

tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/PulsarDebeziumOracleSourceTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@ private void testDebeziumOracleDbConnect(String converterClassName, boolean json
5656
final String sourceName = "test-source-debezium-oracle-" + functionRuntimeType + "-" + randomName(8);
5757

5858
// This is the event count to be created by prepareSource.
59-
final int numMessages = 39;
59+
final int numMessages = 1;
6060

6161
@Cleanup
6262
PulsarClient client = PulsarClient.builder()

0 commit comments

Comments
 (0)