From 185e598d916ddc57992e496928dd4fec4f45930c Mon Sep 17 00:00:00 2001 From: Chris Cranford Date: Wed, 23 Jun 2021 08:00:43 -0400 Subject: [PATCH] DBZ-3645 Fix test failures for Oracle Xstream --- .../io/debezium/connector/oracle/OracleBlobDataTypesIT.java | 2 +- .../java/io/debezium/connector/oracle/OracleClobDataTypeIT.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleBlobDataTypesIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleBlobDataTypesIT.java index bbca091d4..07e3bbaaa 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleBlobDataTypesIT.java +++ b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleBlobDataTypesIT.java @@ -1124,7 +1124,7 @@ record = table.get(1); // Get streaming records sourceRecords = consumeRecordsByTopic(logMinerAdapter ? 3 : 2); table = sourceRecords.recordsForTopic(topicName("DBZ3645")); - assertThat(table).hasSize(3); + assertThat(table).hasSize(logMinerAdapter ? 3 : 2); record = table.get(0); after = ((Struct) record.value()).getStruct(Envelope.FieldName.AFTER); diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleClobDataTypeIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleClobDataTypeIT.java index cbe525a74..85278b10c 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleClobDataTypeIT.java +++ b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleClobDataTypeIT.java @@ -1508,7 +1508,7 @@ record = table.get(1); // Get streaming records sourceRecords = consumeRecordsByTopic(logMinerAdapter ? 3 : 2); table = sourceRecords.recordsForTopic(topicName("DBZ3645")); - assertThat(table).hasSize(3); + assertThat(table).hasSize(logMinerAdapter ? 3 : 2); record = table.get(0); after = ((Struct) record.value()).getStruct(Envelope.FieldName.AFTER);