Details
-
Bug
-
Resolution: Done
-
Critical
-
None
-
False
-
None
-
False
-
Description
Using DBZ version 1.8.0.Final and when we have two fields with the same name ("description" in this case) but belonging to different collections, the connector fails with the following stacktrace:
Caused by: java.lang.IllegalStateException: Duplicate key description (attempted merging values description and description) at java.base/java.util.stream.Collectors.duplicateKeyException(Collectors.java:133) at java.base/java.util.stream.Collectors.lambda$uniqKeysMapAccumulator$1(Collectors.java:180) at java.base/java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169) at java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1655) at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) at java.base/java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) at java.base/java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578) at io.debezium.connector.mongodb.FieldSelector.fieldFilterFor(FieldSelector.java:198) at io.debezium.connector.mongodb.Filters.fieldFilterFor(Filters.java:96) at io.debezium.connector.mongodb.MongoDbSchema.lambda$schemaFor$0(MongoDbSchema.java:75) at java.base/java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1705) at io.debezium.connector.mongodb.MongoDbSchema.schemaFor(MongoDbSchema.java:74) at io.debezium.connector.mongodb.MongoDbSchema.schemaFor(MongoDbSchema.java:30) at io.debezium.pipeline.EventDispatcher.dispatchDataChangeEvent(EventDispatcher.java:204) ... 14 more