[
https://issues.apache.org/jira/browse/FLINK-37943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunshuxian updated FLINK-37943:
-------------------------------
Description:
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
> 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
> Reporter: sunshuxian
> Priority: Major
>
> 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)
