Reverted changes for oracle

datastax · Jul 25, 2024 · 4c58701 · 4c58701
1 parent 4788375
commit 4c58701
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/...org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumOracleDbSourceTester.java b/...org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumOracleDbSourceTester.java
@@ -50,7 +50,7 @@ public DebeziumOracleDbSourceTester(PulsarCluster cluster) {
         super(NAME);
         this.pulsarCluster = cluster;
         this.numEntriesToInsert = 1;
-        this.numEntriesExpectAfterStart = 1;
+        this.numEntriesExpectAfterStart = 0;
 
         pulsarServiceUrl = "pulsar://pulsar-proxy:" + PulsarContainer.BROKER_PORT;
 
@@ -61,7 +61,7 @@ public DebeziumOracleDbSourceTester(PulsarCluster cluster) {
         sourceConfig.put("database.password", "dbz");
         sourceConfig.put("database.server.name", "XE");
         sourceConfig.put("database.dbname", "XE");
-        sourceConfig.put("database.whitelist", "inv");
+        sourceConfig.put("snapshot.mode", "schema_only");
         sourceConfig.put("schema.include.list", "inv");
         sourceConfig.put("schema.history.internal.pulsar.service.url", pulsarServiceUrl);
         sourceConfig.put("topic.namespace", "debezium/oracle");

diff --git a/...g/apache/pulsar/tests/integration/io/sources/debezium/PulsarDebeziumOracleSourceTest.java b/...g/apache/pulsar/tests/integration/io/sources/debezium/PulsarDebeziumOracleSourceTest.java
@@ -56,7 +56,7 @@ private void testDebeziumOracleDbConnect(String converterClassName, boolean json
         final String sourceName = "test-source-debezium-oracle-" + functionRuntimeType + "-" + randomName(8);
 
         // This is the event count to be created by prepareSource.
-        final int numMessages = 39;
+        final int numMessages = 1;
 
         @Cleanup
         PulsarClient client = PulsarClient.builder()