DBZ-3645 Fix test failures for Oracle Xstream

This commit is contained in:
Chris Cranford 2021-06-23 08:00:43 -04:00
parent 6a0005692d
commit 185e598d91
2 changed files with 2 additions and 2 deletions

View File

@ -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);

View File

@ -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);