diff --git a/COPYRIGHT.txt b/COPYRIGHT.txt index 4ad882431..7231cd768 100644 --- a/COPYRIGHT.txt +++ b/COPYRIGHT.txt @@ -208,6 +208,7 @@ Tautvydas Januskevicius Taylor Rolison Theofanis Despoudis Thomas Deblock +Thomas Prelle Tom Bentley Tomaz Lemos Fernandes Tony Rizko diff --git a/debezium-connector-mongodb/src/test/java/io/debezium/connector/mongodb/transforms/ExtractNewDocumentStateTestIT.java b/debezium-connector-mongodb/src/test/java/io/debezium/connector/mongodb/transforms/ExtractNewDocumentStateTestIT.java index e2311dc20..8a1d645cc 100644 --- a/debezium-connector-mongodb/src/test/java/io/debezium/connector/mongodb/transforms/ExtractNewDocumentStateTestIT.java +++ b/debezium-connector-mongodb/src/test/java/io/debezium/connector/mongodb/transforms/ExtractNewDocumentStateTestIT.java @@ -1470,7 +1470,7 @@ public void testShouldThrowExceptionWithElementsDifferingStructures() throws Exc final SourceRecords records = createCreateRecordFromJson("dbz-2316.json"); for (SourceRecord record : records.allRecordsInOrder()) { - final SourceRecord transformed = transformation.apply(record); + transformation.apply(record); } } @@ -1494,11 +1494,22 @@ public void testMatrixType() throws InterruptedException, IOException { + " [7,8,9]," + " ]" + " ,'array_complex': [" - + " {'k1' : 'v1','k2' : 1},{'k1' : 'v2','k2' : 2}," + + " {'k1' : 'v1','k2' : 1}," + + " {'k1' : 'v2','k2' : 2}," + " ]" + " ,'matrix_complex': [" - + " [{'k3' : 'v111','k4' : [1,2,3]},{'k3' : 'v211','k4' : [4,5,6]}]," - + " [{'k3' : 'v112','k4' : [7,8]},{'k3' : 'v212','k4' : [8]}]," + + " [" + + " {'k3' : 'v111'," + + " 'k4' : [1,2,3]}," + + " {'k3' : 'v211'," + + " 'k4' : [4,5,6]}" + + " ]," + + " [" + + " {'k3' : 'v112'," + + " 'k4' : [7,8]}," + + " {'k3' : 'v212'," + + " 'k4' : [8]}" + + " ]," + " ]" + "}")); });