yuxiqian opened a new pull request, #4148: URL: https://github.com/apache/flink-cdc/pull/4148
This closes FLINK-38452. In #2488 we tried to modify how MongoDB CDC connector parses TableId with dots, but it turns out to be an incomplete fix that doesn't cover streaming mode in incremental snapshot mode. The root cause is the `TableId#parse` method assumes `.` is the separator between catalog, schema, and table names, but MongoDB allows dots as a valid character to be presented in collection names. Use `MongoUtils#parseTableId` to resolve the ambiguity. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
