Eason Ye created FLINK-35806: -------------------------------- Summary: [Flink-CDC][MongoDB] Add friendly reminder if the configured collectionList is wrong Key: FLINK-35806 URL: https://issues.apache.org/jira/browse/FLINK-35806 Project: Flink Issue Type: Improvement Components: Flink CDC Affects Versions: cdc-3.1.1 Reporter: Eason Ye
When I used the Datastream API to write a Flink Application to transfer MongoDB's Data to other storage through the Flink CDC MongoDB Source, I didn't configure the correct collectionList. The flink application didn't display any warning log or reminder message. {code:java} MongoDBSource<String> source = MongoDBSource .<String>builder() .scheme("mongodb+srv") ...... .databaseList("demoDB") .collectionList("demoDB.demoCollection") .deserializer(new JsonDebeziumDeserializationSchema()) .startupOptions(StartupOptions.initial()) .build(); {code} I configured the collectionList with "{color:#FF0000}demoCollection{color}" instead of "demoDB.demoCollection", so the flink application can't read data from MongoDB correctly. I hope there could be some logs or reminders for users to figure out the incorrect configuration. Or some downgrade strategy to match and find the exact Collections. -- This message was sent by Atlassian Jira (v8.20.10#820010)