[
https://issues.apache.org/jira/browse/FLINK-37943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17979886#comment-17979886
]
Yanquan Lv commented on FLINK-37943:
------------------------------------
Hi [~xiqian_yu], maybe you can help to check about this.
> mongo cdc bug can not read stream data
> --------------------------------------
>
> Key: FLINK-37943
> URL: https://issues.apache.org/jira/browse/FLINK-37943
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Reporter: sunshuxian
> Priority: Major
> Labels: easyfix
>
> I found a mongo cdc bug, This bug causes the Mongo CDC to malfunction.
> cdc-connector version：2.4.2
> When I have one database and one collection and the collection_name contains
> “.”, it can not be work
> In Master branch partial repairs have been made, see
> org.apache.flink.cdc.connectors.mongodb.source.dialect.{color:#FF0000}MongoDBDialect{color}
>
> {color:#ff8b00}discoverDataCollections {color}Function
> But there are other places that need to be repaired. see
> org.apache.flink.cdc.connectors.mongodb.source.utils.{color:#de350b}MongoUtils{color}
> {color:#ff8b00}getChangeStreamDescriptor {color}Function
> When I have only one database and one collection and collection_name contains
> ".", this code
> ```changeStreamFilter =
> ChangeStreamDescriptor.collection(TableId.parse(discoveredCollections.get(0)));```
> can causing bugs to occur
>
> Please fix in 2.4.2 and the latest version
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
